gevent q demo

gevent_q.py

from gevent import queue


q = queue.Queue()

def queue_put(msg):
    
    q.put_nowait(msg)
    


def queue_get():
    return q.get()
if __name__ == '__main__':
    print "starting ...."
    for i in range(10):
        queue_put(i)
    
    while True:
        try:
            msg = queue_get()
            print msg
        except:
            break