标签：
gevent学习系列第三章，前面两章分析了大量常用几个函数的源码以及实现原理。这一章重点偏向实战了，按照官方给出的gevent学习指南，我将依次分析官方给出的7个数据结构。以及给出几个相应使用他们的例子。
1.事件：
事件是一个可以让我们在Greenlet之间异步通信的形式贴上一个gevent指南上面的例子：
import gevent from gevent.event import Event ‘‘‘ Illustrates the use of events ‘‘‘ evt = Event() def setter(): ‘‘‘After 3 seconds, wake all threads waiting on the value of evt‘‘‘ print(‘A: Hey wait for me, I have to do something‘) gevent.sleep(3) print("Ok, I‘m done") evt.set() def waiter(): ‘‘‘After 3 seconds the get call will unblock‘‘‘ print("I‘ll wait for you") evt.wait() # blocking print("It‘s about time") def main(): gevent.joinall([ gevent.spawn(setter), gevent.spawn(waiter), gevent.spawn(waiter), ]) if __name__ == ‘__main__‘: main()
这里setter和waiter一共起了三个协程。分析一下运行顺序应该很容易了解evt是干嘛的：
首先回调之行到运行setter 打印str然后gevent.sleep(3)。
然后执行第二个回调waitter()执行到evt.wait()的时候阻塞住然后切换，怎么切换的细节要分析的话又是一大波。总之就是切换了
然后执行第三个回调waitter()执行到evt.wait()又被阻塞了，这个时候继续执行下一个回调就会回到setter里面，因为没有人在他前面往hub.loop里注册了
然后这里执行"ok, i‘m done" ok我撸完了，运行evt.set()将flag设置为True.
然后另外两个被阻塞的waitter的evt.wait()方法在看到flag已经为True之后不再继续阻塞运行并且结束。
可以看到，Event可以协同好几个Greenlet同时工作，并且一个主Greenlet在操作的时候可以让其他几个都处于等待的状态，可以实现一些特定的环境和需求。
import gevent from gevent.event import AsyncResult a = AsyncResult() def setter(): """ After 3 seconds set the result of a. """ gevent.sleep(3) a.set(‘Hello!‘) def waiter(): """ After 3 seconds the get call will unblock after the setter puts a value into the AsyncResult. """ print(a.get()) gevent.joinall([ gevent.spawn(setter), gevent.spawn(waiter), ])
Event还有一个扩展AsyncResult， 这个扩展可以在set的时候带上数据传递给各waiter去get。这里get还是会阻塞，但是等待的就是不flag了，而是一个值或一个报错相关更详细的api或更多功能可以参考文档http://www.gevent.org/gevent.event.html。
2: 队列：
队列是一个排序的数据集合，它有常见的put / get操作， 但是它是以在Greenlet之间可以安全操作的方式来实现的。
举例来说，如果一个Greenlet从队列中取出一项，此项就不会被同时执行的其它Greenlet再取到了。可以理解成基于greenlet之间的安全队列吧还是先贴上一个官方的例子：
import gevent from gevent.queue import Queue tasks = Queue() def worker(n): while not tasks.empty(): task = tasks.get() print(‘Worker %s got task %s‘ % (n, task)) gevent.sleep(0) print(‘Quitting time!‘) def boss(): for i in xrange(1,25): tasks.put_nowait(i) gevent.spawn(boss).join() gevent.joinall([ gevent.spawn(worker, ‘steve‘), gevent.spawn(worker, ‘john‘), gevent.spawn(worker, ‘nancy‘), ])
首先初始化一个Queue()实例。这里会先运行boss() 调用put_nowait()方法不阻塞的往队列里面放24个元素。然后下面依次从Queue里对数字进行消费，起了三个协程分别命名了不同的名字，使用get方法依次消费队列里面的数字直到消费完毕。
put和get操作都有非阻塞的版本，put_nowait和get_nowait不会阻塞， 然而在操作不能完成时抛出gevent.queue.Empty或gevent.queue.Full异常。同时Queue队列可以支持设置最大队列值，查看队列现在元素数量qsize(),队列是否为空empty()，队列是否满了full()等api在使用的时候最好也参考一下文档：http://www.gevent.org/gevent.queue.html
3.Group gevent文档翻译为组合池：
to be continue.....
等我看了multiprocessing模块再来理解一下这里。
python 协程库gevent学习--gevent数据结构及实战(三)
标签：
原文地址：http://www.cnblogs.com/piperck/p/5719733.html
