Go-并发模式1(Basic Examples)

Posted 2021-09-22 lady_killer9

目录

一个无聊的函数

稍微无聊的函数

使用goroutine

使用goroutine并等待一段时间

使用通道channels

参考

---

一个无聊的函数

package main

import (
	"fmt"
	"time"
)

func main() {
	boring("boring!")
}

func boring(msg string) {
	for i := 0; ; i++ {
		fmt.Println(msg, i)
		time.Sleep(time.Second)
	}
}

过一秒输出一下boring! 加数字，结果如下：

稍微无聊的函数

package main

import (
	"fmt"
	"math/rand"
	"time"
)

func main() {
	boring("boring!")
}

// START OMIT
func boring(msg string) {
	for i := 0; ; i++ {
		fmt.Println(msg, i)
		time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
	}
}

不再等待一个固定的时间 

使用goroutine

package main

import (
	"fmt"
	"math/rand"
	"time"
)

func main() {
	go boring("boring!")
}

func boring(msg string) {
	for i := 0; ; i++ {
		fmt.Println(msg, i)
		time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
	}
}

我们在main函数中使用goroutine来运行go函数，结果

 是的，没有错，直接结束了程序，因为在go中不会默认等待goroutine结束

使用goroutine并等待一段时间

package main

import (
	"fmt"
	"math/rand"
	"time"
)

func main() {
	go boring("boring!")
	fmt.Println("I'm listening.")
	time.Sleep(2 * time.Second)
	fmt.Println("You're boring; I'm leaving.")
}

func boring(msg string) {
	for i := 0; ; i++ {
		fmt.Println(msg, i)
		time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
	}
}

在main函数中等待了2秒，然后结束

什么是goroutine呢？

goroutine是独立运行的函数。它有自己的调用栈，不是线程，可能成千上万个goroutine只有一个线程，根据需要将goroutine动态地多路复用到线程上，以保持所有goroutine的运行。

通信

前面的例子给了大家一个假象，仿佛知道goroutine在运行什么，输出什么。但实际上，我们无法得知goroutine应该运行多长时间。因此，我们需要通信来进行更好的程序衔接与合作，这就引出了channel。

使用通道channels

package main

import (
	"fmt"
	"math/rand"
	"time"
)

func main() {
	c := make(chan string)
	go boring("boring!", c)
	for i := 0; i < 5; i++ {
		fmt.Printf("You say: %q\\n", <-c) // Receive expression is just a value.
	}
	fmt.Println("You're boring; I'm leaving.")
}

func boring(msg string, c chan string) {
	for i := 0; ; i++ {
		c <- fmt.Sprintf("%s %d", msg, i) // Expression to be sent can be any suitable value.
		time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
	}
}

使用channel进行通信，goroutine的函数一直向channel中放数据，main中从channel获取 

同步
当主函数执行<–c时，它将等待发送值。
类似地，当boring函数执行c<–value时，它会等待接收者准备就绪。
发送方和接收方都必须准备好在通信中发挥作用。
因此，通道既通信又同步。Go 通过交流来分享数据，而不是通过分享数据来交流！

至此，和现实生产有点像了。 

channel可以有buffer，类似e-mail，这里不会涉及。

参考

Google IO 2012 Go Concurrency Patterns

b站中文字幕版

PPT

全部代码

 更多Go相关内容：Go-Golang学习总结笔记

有问题请下方评论，转载请注明出处，并附有原文链接，谢谢！如有侵权，请及时联系。如果您感觉有所收获，自愿打赏，可选择支付宝18833895206（小于），您的支持是我不断更新的动力。