Author Commit Message Labels Comments Date
update version for map_async change
If callback function given, then callback send response.
submit async needs to pass chunksize
Executor map() and map_async() methods take optional chunksize parameter to limit concurrenty. This lets caller avoid using too many threads when processing many items.
Update version for changes to map_ mathods.
Calling an Executor's map() and map_async() methods is no longer restricted to a single parameter per call.
Executor class provides common interface and functionality for ThreadPool calsses.
Added ThreadRunner class that is like ThreadPool, but runs each submitted task in a new thread.
Submitting task to ThreadPool returns a completion object, same as with submitting a task to the Reactor.
ThreadPool: replace __len__() with threads() for getting number of threads in thread pool. More explicit meaning, so clearer and less change of unexpected behavior. Renamed get_idle_threads() to idle_threads(), get_queue_size() to qsize().
Reactor.shutdown() takes optional parameter to shutdown threadpool. Reactor.shutdown() returns True on success.
Fix decreasing pool size when too many idle threads.
Remove bad assert
Add printing back into unit test. Reformat output.
Added call_at() method to Reactor.
- ThreadPool can now, optionally, automatically resize itself.
update version
Fix import issue.
update version
- Result is not available until callback completes. This allows caller waiting on result to reliably handle exception in callback.
In reactor call_ methods, optionally specify a queue to put Result objects one when the associated function has completed.
Fix spelling in README
Update README. Add so that examples are included in source dist.
Fix setup issue with python3. Add example.
Code is python3 compatible.
Fix wiki link
Update README.
initial commit