ThreadPoolExecutor with the ability to bump waited futures to the front
Project description
tpe_prio
Use like a regular concurrent.futures.ThreadPoolExecutor
except there is now a
bump(fut)
method. During execution, the deque gets rotated and put back, so
it is possible that workers will pick up a non-optimal next choice for a small
window of time.
License
tpe_prio is copyright Tim Hatch, and licensed under
the MIT license. I am providing code in this repository to you under an open
source license. This is my personal repository; the license you receive to
my code is from me and not from my employer. See the LICENSE
file for details.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
tpe-prio-0.1.0.tar.gz
(6.0 kB
view hashes)