gevent.queue – Synchronized queues

exception Full

An alias for Queue.Full

exception Empty

An alias for Queue.Empty

Example of how to wait for enqueued tasks to be completed:

def worker():
    while True:
        item = q.get()
        try:
            do_work(item)
        finally:
            q.task_done()

q = JoinableQueue()
for i in range(num_worker_threads):
     gevent.spawn(worker)

for item in source():
    q.put(item)

q.join()  # block until all tasks are done

Next page: gevent.coros – Locking primitives