Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import gevent
- from gevent.event import AsyncResult
- a = AsyncResult()
- def setter():
- print("1")
- print("2")
- print("3")
- gevent.sleep(3)
- a.set(4) # wakeup waiter and send value "4"
- def waiter():
- """
- After 3 seconds the get call will unblock.
- """
- val = a.get() # blocking
- print(val) # val is 4 (from setter)
- print("5")
- print 'I live!'
- gevent.joinall([
- gevent.spawn(setter),
- gevent.spawn(waiter),
- ])
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement