Go-并发模式1(Basic Examples)

比眉伴天荒 2022-09-10 08:20 47阅读 0赞

**目录**

一个无聊的函数

稍微无聊的函数

使用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! 加数字，结果如下：

![20210906210918147.PNG][]

# 稍微无聊的函数 #

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)
    	}
    }

不再等待一个固定的时间

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAbGFkeV9raWxsZXI5_size_20_color_FFFFFF_t_70_g_se_x_16][]

# 使用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函数，结果

![20210906211714740.PNG][]

是的，没有错，直接结束了程序，因为在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秒，然后结束

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAbGFkeV9raWxsZXI5_size_20_color_FFFFFF_t_70_g_se_x_16 1][]

**什么是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 通过交流来分享数据，而不是通过分享数据来交流！

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAbGFkeV9raWxsZXI5_size_20_color_FFFFFF_t_70_g_se_x_16 2][]

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

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

# 参考 #

[Google IO 2012 Go Concurrency Patterns][]

[b站中文字幕版][b]

[PPT][]

[全部代码][Link 1]

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

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

[20210906210918147.PNG]: /images/20220829/7ea8b2540ae64536811ffa41e9e4fd2d.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAbGFkeV9raWxsZXI5_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/3e428653d7494ed28e08ee75dd7dcc0d.png
[20210906211714740.PNG]: /images/20220829/ec3c8d257f7c464c92610f5f41418c49.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAbGFkeV9raWxsZXI5_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220829/73d9e484347d4e5e8929cc7bad07525b.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAbGFkeV9raWxsZXI5_size_20_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220829/b6372aa504144f66b265bde8231f5790.png
[Google IO 2012 Go Concurrency Patterns]: https://www.youtube.com/watch?v=f6kdp27TYZs
[b]: https://www.bilibili.com/video/BV1UJ411m7U1/
[PPT]: https://talks.golang.org/2012/concurrency.slide#1
[Link 1]: https://gitee.com/frankyu365/google-io-2012-go-concurrency-patterns
[Go-Golang]: https://blog.csdn.net/lady_killer9/article/details/115491317