Skip to content

Add concurrent.futures.Executor implementation #235

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
wants to merge 19 commits into
base: main
Choose a base branch
from
Draft

Add concurrent.futures.Executor implementation #235

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
648b700
Add concurrent.futures.Executor implementation
nchristensen Nov 20, 2022
5e8ecb2
Use Task instead of map_async in PoolExecutor
nchristensen Nov 20, 2022
6f5558b
Update shutdown status of PoolExecutor
nchristensen Nov 20, 2022
ba3ec79
Add future cancelling support
nchristensen Nov 21, 2022
3f6291e
Remove stray colon
nchristensen Nov 21, 2022
b71a5a5
Raise error if kwargs are used in submit, add cancelled property to f…
nchristensen Nov 21, 2022
1a5280a
Better cancelling check, remove asyncio timeout
nchristensen Nov 21, 2022
559546e
Run autopep8 on pool.py and thread.py
nchristensen Nov 21, 2022
1b08833
Simplify shutdown code
nchristensen Nov 21, 2022
08cf569
Support wait and cancel_futures in shutdown
nchristensen Nov 21, 2022
7a2ce28
Implement timeout with gevent
nchristensen Nov 21, 2022
42d32e1
Add self as argument to add_done_callback
nchristensen Nov 21, 2022
ccf62e6
Use concurrent.futures.wait in shutdown
nchristensen Nov 21, 2022
56fe0bc
Add remainder of concurrent.futures.Future API
nchristensen Nov 22, 2022
9822860
Refine add callback function
nchristensen Nov 22, 2022
282a11b
Simplify running callbacks, use get() to wait on futures during shutdown
nchristensen Dec 6, 2022
b71e4b3
Fix PoolExecutor.map
nchristensen Dec 6, 2022
081d3dc
Use more of the Futures interface
nchristensen Dec 7, 2022
2bbb9a8
Hack to make submit work
nchristensen Dec 7, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Loading