A thread pool that auto-manages the number of worker threads and is compatible with the "futures" module ThreadPoolExecutor interface.
Project description
# CollapsingThreadPoolExecutor
The CollapsingThreadPoolExecutor is inspired by and compatible with the ThreadPoolExecutor from the
"futures" module, it operates differently in that worker threads are handled with a stack which results in the same worker or workers doing all the work (and idle workers being destroyed).
## How to install
$ pip install collapsing-thread-pool-executor
## How to develop
**Prerequisites**
* python3 w/ pip
* python2 w/ pip
* virtualenvwrapper
* entr
**Set up the environments**
$ mkvirtualenv -p `which python2.7` collapsing-thread-pool-executor-py2
$ pip install .
$ pip install -r requirements.txt
$ mkvirtualenv -p `which python3` collapsing-thread-pool-executor-py3
$ pip install .
$ pip install -r requirements.txt
**Watch the tests**
# watch python2 tests in one window
$ workon collapsing-thread-pool-executor-py2
$ find ./ -name '*.py' | entr -c py.test -v --log-level=DEBUG collapsing_thread_pool_executor
# watch python3 tests in one window
$ workon collapsing-thread-pool-executor-py3
$ find ./ -name '*.py' | entr -c py.test -v --log-level=DEBUG collapsing_thread_pool_executor
## Examples
The example below will execute `some_task()` 100 times; as `some_task()` should take a second to execute and as we've allocated 10 workers, the whole thing should take about 10 seconds.
import time
from collapsing_thread_pool_executor import CollapsingThreadPoolExecutor
def some_task():
time.sleep(1)
# all arguments are optional
pool = CollapsingThreadPoolExecutor(
workers=10,
thread_name_prefix='SomePool',
permitted_thread_age_in_seconds=60,
)
for i in range(0, 100):
pool.submit(some_task)
The CollapsingThreadPoolExecutor is inspired by and compatible with the ThreadPoolExecutor from the
"futures" module, it operates differently in that worker threads are handled with a stack which results in the same worker or workers doing all the work (and idle workers being destroyed).
## How to install
$ pip install collapsing-thread-pool-executor
## How to develop
**Prerequisites**
* python3 w/ pip
* python2 w/ pip
* virtualenvwrapper
* entr
**Set up the environments**
$ mkvirtualenv -p `which python2.7` collapsing-thread-pool-executor-py2
$ pip install .
$ pip install -r requirements.txt
$ mkvirtualenv -p `which python3` collapsing-thread-pool-executor-py3
$ pip install .
$ pip install -r requirements.txt
**Watch the tests**
# watch python2 tests in one window
$ workon collapsing-thread-pool-executor-py2
$ find ./ -name '*.py' | entr -c py.test -v --log-level=DEBUG collapsing_thread_pool_executor
# watch python3 tests in one window
$ workon collapsing-thread-pool-executor-py3
$ find ./ -name '*.py' | entr -c py.test -v --log-level=DEBUG collapsing_thread_pool_executor
## Examples
The example below will execute `some_task()` 100 times; as `some_task()` should take a second to execute and as we've allocated 10 workers, the whole thing should take about 10 seconds.
import time
from collapsing_thread_pool_executor import CollapsingThreadPoolExecutor
def some_task():
time.sleep(1)
# all arguments are optional
pool = CollapsingThreadPoolExecutor(
workers=10,
thread_name_prefix='SomePool',
permitted_thread_age_in_seconds=60,
)
for i in range(0, 100):
pool.submit(some_task)
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
Built Distribution
Close
Hashes for collapsing-thread-pool-executor-2018.6.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 1abcfe023e5ba5a5a46f2f6e693d24d5fc34a49271480e18f37338e72ee97f73 |
|
MD5 | 1572225f0573c8a65bd3672b67c3017b |
|
BLAKE2b-256 | 532c617bd9e1b670b873ca0a1a88c636fdeae322f67981cbffa08ade20540e07 |
Close
Hashes for collapsing_thread_pool_executor-2018.6-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | ddc996e762e6600443c0ba847a8a0d70791fdc647f0cb25fe0ecb8c7420da1f6 |
|
MD5 | 1532bc57a6cfbf53ed9051898a189edb |
|
BLAKE2b-256 | aa2db25036fac734f699279105d7c6445baaf3b0f501f84c08afbc5931868941 |