【发布时间】:2016-01-01 09:36:26
【问题描述】:
import gevent
from gevent.event import AsyncResult
import time
class Job(object):
def __init__(self, name):
self.name = name
def setter(job):
print 'starting'
gevent.sleep(3)
job.result.set('%s done' % job.name)
def waiter(job):
print job.result.get()
# event loop
running = []
for i in range(5):
print 'creating'
j = Job(i)
j.result = AsyncResult()
running.append(gevent.spawn(setter, j))
running.append(gevent.spawn(waiter, j))
print 'started greenlets, event loop go do something else'
time.sleep(5)
gevent.joinall(running)
直到joinall 被调用,gevent 才真正开始
- 有什么东西会异步启动/生成 gevent(为什么它不会在调用 spawn 时立即启动)?
- 在运行greenlets 时是否有
select/epoll 来查看需要加入哪个而不是joinall()?
【问题讨论】: