Go 并发实现协程同步的多种解决方法

￡神魔★判官ぃ 2024-03-22 23:42 46阅读 0赞

![ef459d914d540558fce22820056514c0.jpeg][]

![208.jpg][]

本文主要介绍了Go 并发——实现协程同步的多种解决方法，非常不错，具有一定的参考借鉴价值,需要的朋友可以参考下

**go 简洁的并发**

多核处理器越来越普及。有没有一种简单的办法，能够让我们写的软件释放多核的威力？是有的。随着Golang, Erlang, Scala等为并发设计的程序语言的兴起，新的并发模式逐渐清晰。正如过程式编程和面向对象一样，一个好的编程模式有一个极其简洁的内核，还有在此之上丰富的外延。可以解决现实世界中各种各样的问题。本文以GO语言为例，解释其中内核、外延。

**前言**

Java 中有一系列的线程同步的方法，go 里面有 goroutine（协程），先看下下面的代码执行的结果是什么呢？

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 </td> 
 <td> <code>package main</code> <code>&nbsp;</code><code>import</code> <code>(</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"fmt"</code> <code>)</code> <code>&nbsp;</code><code>func main() { </code> <code>&nbsp;&nbsp;</code><code>go func() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>fmt</code><code>.Println(</code><code>"Goroutine 1"</code><code>)</code> <code>&nbsp;&nbsp;</code><code>}()</code> <code>&nbsp;&nbsp;</code><code>go func() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>fmt</code><code>.Println(</code><code>"Goroutine 2"</code><code>)</code> <code>&nbsp;&nbsp;</code><code>}()</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

执行以上代码很可能看不到输出。

因为有可能这两个协程还没得到执行，主协程就已经结束了，而主协程结束时会结束所有其他协程，所以导致代码运行的结果什么都没有。

可能会问那么该如何等待主协程中创建的协程执行完毕之后再结束主协程呢？

**下面说几种可以解决的方法：**

**Sleep 一段时间**

在 main 方法退出之前 sleep 一段时间就可能会出现结果了，如下代码：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 </td> 
 <td> <code>package main</code> <code>&nbsp;</code><code>import</code> <code>(</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"fmt"</code> <code>&nbsp;&nbsp;</code><code>"time"</code> <code>&nbsp;</code><code>)</code> <code>&nbsp;</code><code>func main() { </code> <code>&nbsp;&nbsp;&nbsp;</code><code>go func() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>fmt</code><code>.Println(</code><code>"Goroutine 1"</code><code>)</code> <code>&nbsp;&nbsp;</code><code>}()</code> <code>&nbsp;&nbsp;</code><code>go func() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>fmt</code><code>.Println(</code><code>"Goroutine 2"</code><code>)</code> <code>&nbsp;&nbsp;</code><code>}()</code> <code>&nbsp;&nbsp;</code><code>time</code><code>.Sleep(</code><code>time</code><code>.Second * 1) </code><code>//</code> <code>睡眠1秒，等待上面两个协程结束</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

这两个简单的协程执行消耗的时间很短的，所以你会发现现在就有结果出现了。

> Goroutine 1  
> Goroutine 2

为什么上面我要说 “可能会出现” ？

因为 sleep 这个时间目前是设置的 1s，如果我这两个协程里面执行了很复杂的逻辑操作（时间大于 1s），那么就会发现依旧也是无结果打印出来的。

那么就可以发现这种方式得到问题所在了：我们无法确定需要睡眠多久

上面那种方式有问题，go 里面其实也可以用管道来实现同步的。

**管道实现同步**

那么用管道怎么实现同步呢？show code：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 </td> 
 <td> <code>package main</code> <code>&nbsp;</code><code>import</code> <code>(</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"fmt"</code> <code>&nbsp;</code><code>)</code> <code>&nbsp;</code><code>func main() { </code> <code>&nbsp;&nbsp;&nbsp;</code><code>ch := </code><code>make</code><code>(chan struct{})</code> <code>&nbsp;&nbsp;</code><code>count := 2 </code><code>//</code> <code>count 表示活动的协程个数</code> <code>&nbsp;&nbsp;</code><code>go func() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>fmt</code><code>.Println(</code><code>"Goroutine 1"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ch &lt;- struct{}{} </code><code>//</code> <code>协程结束，发出信号</code> <code>&nbsp;&nbsp;</code><code>}()</code> <code>&nbsp;&nbsp;</code><code>go func() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>fmt</code><code>.Println(</code><code>"Goroutine 2"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ch &lt;- struct{}{} </code><code>//</code> <code>协程结束，发出信号</code> <code>&nbsp;&nbsp;</code><code>}()</code> <code>&nbsp;&nbsp;</code><code>for</code> <code>range ch { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//</code> <code>每次从ch中接收数据，表明一个活动的协程结束</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>count--</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//</code> <code>当所有活动的协程都结束时，关闭管道</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>count == 0 { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>close(ch)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

这种方式是一种比较完美的解决方案， goroutine / channel 它们也是在 go 里面经常搭配在一起的一对。

**sync.WaitGroup**

其实 go 里面也提供了更简单的方式 —— 使用 sync.WaitGroup。

WaitGroup 顾名思义，就是用来等待一组操作完成的。WaitGroup 内部实现了一个计数器，用来记录未完成的操作个数，它提供了三个方法：

*  Add() 用来添加计数
 *  Done() 用来在操作结束时调用，使计数减一
 *  Wait() 用来等待所有的操作结束，即计数变为 0，该函数会在计数不为 0 时等待，在计数为 0 时立即返回

继续 show code：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 </td> 
 <td> <code>package main</code> <code>&nbsp;</code><code>import</code> <code>(</code> <code>&nbsp;&nbsp;&nbsp;</code><code>"fmt"</code> <code>&nbsp;&nbsp;</code><code>"sync"</code> <code>&nbsp;</code><code>)</code> <code>&nbsp;</code><code>func main() { </code> <code>&nbsp;&nbsp;</code><code>var wg </code><code>sync</code><code>.WaitGroup</code> <code>&nbsp;&nbsp;</code><code>wg.Add(2) </code><code>//</code> <code>因为有两个动作，所以增加2个计数</code> <code>&nbsp;&nbsp;</code><code>go func() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>fmt</code><code>.Println(</code><code>"Goroutine 1"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>wg.Done() </code><code>//</code> <code>操作完成，减少一个计数</code> <code>&nbsp;&nbsp;</code><code>}()</code> <code>&nbsp;&nbsp;</code><code>go func() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>fmt</code><code>.Println(</code><code>"Goroutine 2"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>wg.Done() </code><code>//</code> <code>操作完成，减少一个计数</code> <code>&nbsp;&nbsp;</code><code>}()</code> <code>&nbsp;&nbsp;</code><code>wg.Wait() </code><code>//</code> <code>等待，直到计数为0</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

你会发现也是可以看到运行结果的，是不是发现这种方式是很简单的。

**总结**

以上所述是小编给大家介绍的Go 并发实现协程同步的多种解决方法，希望对大家有所帮助！

转自：[微点阅读][Link 1] [https://www.weidianyuedu.com][https_www.weidianyuedu.com]

[ef459d914d540558fce22820056514c0.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/4ab49967c3f347d38555d425819b9393.png
[208.jpg]: https://images.weidianyuedu.com/thumb/208.jpg
[Link 1]: https://m.weidianyuedu.com/
[https_www.weidianyuedu.com]: https://www.weidianyuedu.com