Gevent Queue example

gevent_queue_example.py

from gevent.queue import Queue

message_queue = Queue()

def receiver(n):
    while not message_queue.empty():
        message = message_queue.get()
        print('Received %s  message %s' % (n, message))
        gevent.sleep(0)

    print('Quitting time!')

def sender():
    for i in xrange(1,25):
        message_queue.put_nowait(i)

gevent.spawn(sender).join()

gevent.joinall([
    gevent.spawn(receiver, 'steve'),
    gevent.spawn(receiver, 'john'),
    gevent.spawn(receiver, 'nancy'),
    ])