用生产者消费者理解golang channel

Python018

用生产者消费者理解golang channel,第1张

生产者消费者问题是一个著名的线程同步问题,该问题描述如下:有一个生产者在生产产品,这些产品将提供给若干个消费者去消费,为了使生产者和消费者能并发执行,在两者之间设置一个具有多个缓冲区的缓冲池,生产者将它生产的产品放入一个缓冲区中,消费者可以从缓冲区中取走产品进行消费,显然生产者和消费者之间必须保持同步,即不允许消费者到一个空的缓冲区中取产品,也不允许生产者向一个已经放入产品的缓冲区中再次投放产品。

golang 的channel天生具有这种特性,即

①缓冲区满时写,缓冲区空时读,都会阻塞。

②channel 本身就是并发安全的。

golang实现多生产者多消费者:

运行结果:

可以看出,用golang实现生产者消费者非常简单,PV操作不需要各种加锁解锁,奥妙就在于CSP模型,即golang提倡的用通信代替共享内存。

packagemain

import(

"fmt"

"sync"

)

//实现一个生产者和消费者

/*生产者产生数据添加到通道里面,消费者消费数据从通道里面

不带缓存实现

*/

funcmain(){

ch:=make(chanint)

varwgsync.WaitGroup

wg.Add(2)

goproducers(&wg,ch)

goconsumer(&wg,ch)

wg.Wait()

}

//生产者

funcproducers(wg*sync.WaitGroup,chchanint){

fori:=0i<10i++{

fmt.Println("send:",i)

ch<-i

}

close(ch)

wg.Done()

}

//消费者

funcconsumer(wg*sync.WaitGroup,chchanint){

forv:=rangech{

fmt.Println("recv:",v)

}

wg.Done()

}

���$�