Synchronization primitives for Tornado coroutines.
Project description
- Info:
Synchronization primitives for Tornado coroutines.
- Author:
A. Jesse Jiryu Davis
Documentation: http://toro.readthedocs.org/
About
A set of locking and synchronizing primitives analogous to those in Python’s threading module or Gevent’s coros, for use with Tornado’s gen.engine.
Dependencies
Tornado >= version 2.3.
Examples
Here’s a basic example (for more see the examples section of the docs):
from tornado import ioloop, gen import toro q = toro.JoinableQueue(maxsize=3) @gen.engine def consumer(): while True: item = yield gen.Task(q.get) try: print 'Doing work on', item finally: q.task_done() @gen.engine def producer(): for item in range(10): yield gen.Task(q.put, item) producer() consumer() loop = ioloop.IOLoop.instance() q.join(callback=loop.stop) # block until all tasks are done loop.start()
Documentation
You will need Sphinx and GraphViz installed to generate the documentation. Documentation can be generated like:
$ sphinx-build doc build
Testing
Run python setup.py nosetests in the root directory.
Toro boasts 100% code coverage, including branch-coverage!
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
toro-0.4.tar.gz
(59.0 kB
view hashes)