golang并发编程实践 -- 简单生产者消费者(with lock)

大佬教程收集整理的这篇文章主要介绍了golang并发编程实践 -- 简单生产者消费者(with lock)，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

上一篇文章用golang中的chAnnel实现了简单的消费者模型，下面的版本是用传统的锁技术实现的版本，相对比会发现golang提供的chAnnel更好用。而且golang的chAnnel可以完成很多在别的语言里需要很多代码才能实现的功能。以后陆续解答。

@H_944_6@package main import ( "fmt" "sync" "time" ) type Queue struct { Elem []int Capacity int Front int Rear int Lock sync.Locker Cond *sync.Cond } func New() *Queue { theQueue := &Queue{} theQueue.Capacity = 10 theQueue.Elem = make([]int,10) theQueue.Front,theQueue.Rear = 0,0 theQueue.Lock = &sync.Mutex{} theQueue.Cond = sync.NewCond(theQueue.Lock) return theQueue } func (self *QueuE) Put(E int) { self.Cond.l.Lock() // the Queue is full,Producer waits here // note that we use for not if to test the condition for self.Full() { self.Cond.Wait() } self.Elem[self.Rear] = e self.Rear = (self.Rear + 1) % self.Capacity self.Cond.Signal() defer self.Cond.l.Unlock() } func (self *QueuE) Get() int { self.Cond.l.Lock() // the Queue is empty,Consumer waits here // note that we use for not if to test the condition for self.Empty() { self.Cond.Wait() } p := self.Elem[self.Front] self.Front = (self.Front + 1) % self.Capacity self.Cond.Signal() defer self.Cond.l.Unlock() return p } func (self *QueuE) Empty() bool { if self.Front == self.Rear { return true } return false } func (self *QueuE) Full() bool { if ((self.Rear + 1) % self.Capacity) == self.Front { return true } return false } func main() { theQueue := New() // producer puts go func() { for i := 1; i <= 100; i++ { time.Sleep(100 * time.Millisecond) theQueue.Put(i) fmt.Println("Bob puts ",i) } }() // consumer gets for i := 1; i <= 100; i++ { time.Sleep(100 * time.Millisecond) p := theQueue.Get() fmt.Println("Alice gets : ",p) } }

运行效果如下：

Bob puts  1
Alice gets :  1
Bob puts  2
Alice gets :  2
Bob puts  3
Alice gets :  3
Bob puts  4
Alice gets :  4
Bob puts  5
Alice gets :  5
Bob puts  6
Alice gets :  6
Bob puts  7
Alice gets :  7
Bob puts  8
Alice gets :  8
Bob puts  9
Alice gets :  9
Bob puts  10
Alice gets :  10
Bob puts  11
Alice gets :  11
Bob puts  12
Alice gets :  12
Bob puts  13
Alice gets :  13

.......

如此反复直到100次。

大佬总结

以上是大佬教程为你收集整理的golang并发编程实践 -- 简单生产者消费者(with lock)全部内容，希望文章能够帮你解决golang并发编程实践 -- 简单生产者消费者(with lock)所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。