File: gevent.queue.rst

package info (click to toggle)
python-gevent 1.0.1-2
  • links: PTS
  • area: main
  • in suites: jessie, jessie-kfreebsd
  • size: 9,948 kB
  • ctags: 12,954
  • sloc: python: 39,061; ansic: 26,289; sh: 13,582; makefile: 833; awk: 18
file content (34 lines) | stat: -rw-r--r-- 667 bytes parent folder | download | duplicates (4) 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
 
:mod:`gevent.queue` -- Synchronized queues
==========================================

.. automodule:: gevent.queue
	:members:
	:undoc-members:

.. exception:: Full

    An alias for :class:`Queue.Full`

.. exception:: Empty

    An alias for :class:`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