欢迎光临
我们一直在努力

生产者-消费者模式

生产者-消费者模式

这篇文章介绍了 goroutine 和 channels。这是 go 中最有用的两个结构。如果正确使用,它们可以为开发人员提供处理并发性的极大灵活性。它们是采访中最常见的话题之一。

在go中实现简单的生产者消费者模式。

var buffer = make(chan int, 5)

func produce(wg *sync.WaitGroup) {
    defer wg.Done()
    for i := 0; i 



<p>这是最简单的实现之一;但这种模式很常见。我们有一个“生成”值的线程和一个必须“消耗”它们的线程。在<a style="color:#f60; text-decoration:underline;" href="https://www.codesou.cn/" target="_blank">golang</a>中,在线程之间传递这些值的方式是通道。</p>

<p>我们首先为整数创建一个通道。然后创建实现生产者和消费者函数的例程。</p>

<p>在任何多线程情况下,同步都是一个问题。 golang 创建了 waitgroup 作为实现同步的一种手段。它们只是作为计数器工作,需要同步的线程将等待,直到计数为 0。控制线程使用 done() 函数来递减计数器。</p>

<p>在这个问题中,我们为生产者和消费者创建一个 waitgroup,并将两者初始化为计数 1(使用 add() 函数)。</p>

<p>主线程启动生产者、消费者和一个等待生产者的内联线程,然后等待消费者完成。 </p>

<p>生产者线程开始正常发送数据。完成后,它使用 waitgroup 来表示已完成向通道的发送。内联 goroutine 等待关闭通道的生产者 waitgroup。如果通道永远不会关闭,消费者将永远休眠等待更多数据,并且进程永远不会终止。</p>

<p>当消费者没有更多数据时(因为通道已关闭),它通知第二个 waitgroup 已完成。</p>

<p>启动生产者和消费者线程的主线程会等待,直到消费者 waitgroup 允许它完成。这可以防止主线程过早终止,从而杀死进程中的所有线程。</p>

<p>这不是实现生产者-消费者模式的唯一方法。 </p>

<p>还有一些问题,例如 sigterm 和 sigint 等信号的外部终止,需要在生产代码中解决。这是一个简单的演示,展示了基础知识。</p>

<p>您还会如何实现它?上述实现中缺少什么?在下面发表您的评论或其他实现的链接。</p>

<p>谢谢!</p>

<p><em>这篇文章以及本系列所有文章的代码可以在这里找到</em></p>


          

            
  

            
        
赞(0) 打赏
未经允许不得转载:码农资源网 » 生产者-消费者模式
分享到

觉得文章有用就打赏一下文章作者

非常感谢你的打赏,我们将继续提供更多优质内容,让我们一起创建更加美好的网络世界!

支付宝扫一扫打赏

微信扫一扫打赏

登录

找回密码

注册