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模块再来理解一下这里。