simpleflow
simpleflow copied to clipboard
Feature/async local executor
A preview for an asynchronous local executor.
It uses the module concurrent.futures which is back-ported to python2.
It introduces an AdaptorFuture that covers the semantic gap between simpleflow's Future and concurrent.futures's Future object. The real job is forwarded to concurrent.futures's ThreadPoolExecutor.
ProcessPoolExecutor seems a better choice but there's a serialization problem (see inline comment).
Also simpleflow.futures.wait method should not raise ExecutionBlocked exception.