golang 的channel天生具有这种特性,即
①缓冲区满时写,缓冲区空时读,都会阻塞。
②channel 本身就是并发安全的。
golang实现多生产者多消费者:
运行结果:
可以看出,用golang实现生产者消费者非常简单,PV操作不需要各种加锁解锁,奥妙就在于CSP模型,即golang提倡的用通信代替共享内存。
packagemainimport(
"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()
}
���$�