goodwritehq/threadloop

Tornado IOLoop Backed Concurrent Futures

ThreadLoop

Run Tornado Coroutines from Synchronous Python.

from threadloop import ThreadLoop
from tornado import gen

@gen.coroutine
def coroutine(greeting="Goodbye"):
    yield gen.sleep(1)
    raise gen.Return("%s World" % greeting)

with ThreadLoop() as threadloop:
    future = threadloop.submit(coroutine, "Hello")

    print future.result() # Hello World

threadloop's Issues

Add support for Python 3.5

Test that timeouts work.

Support other ioloops

Wondering if its possible to allow the ioloop to be injected... would need to either a common API to interact with them (start, stop, and add_callback). Or potentially Tornado's Twisted & AsyncIO bridge already works and we'd just provide documentation.

Verify thread safety

Need to determine a way to test if this lib is threadsafe or not...

PyPI sdist doesnt include LICENSE

Add support for extensive version testing.

Currently there is only a handful of Python version testing; we should add all of the common ones if possible.

Exception stack is not maintained when thread crashes.

^C Signal does not kill program.

Add test verifying that main thread can exit

@abhinav thought we might be able to use multiprocessing to simulate the different use-cases.

• when a script is ran, and the natural exit of the script is it finishing
• when a signal is sent to the process, killing the process
• when there is still work in flight in the ioloop

Documentation

Currently there isn't any documentation at all.

• docblocks
• README.md