execute multiple async tasks as simple as possible
Project description
simple_multiprocessing
Description
execute multiple async tasks (via multiprocessing.Process, or threadingThread) as simple as possible
Install
pip install simple_multiprocessing
# or
pip3 install simple_multiprocessing
Usage
from simple_multiprocessing import MultiThread, MultiProcess, Task
import random, time
def test(i: int) -> float:
print('started:', i)
start = time.time()
if random.random() < 0.5:
while True:
time.sleep(0.01)
res = time.time() - start
return res#time.time() - start
tasks = [Task(test, i) for i in range(5)]
[print(i, type(r), r) for i, r in enumerate(MultiThread(tasks).solve(timeout=1))]
[print(i, type(r), r) for i, r in enumerate(MultiProcess(tasks).solve(timeout=1))]
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 simple_multiprocessing-0.0.9.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 4dacbdc0800334b915fe072144d21ef8f0f3944a112897cc66e25b377b4d50b8 |
|
MD5 | 6f824dfcff9f08a50e6bc012665e8258 |
|
BLAKE2b-256 | 6aef5b51204afdc336a6d1d828c59017229b9f4b7e7000408fd48fb2e9a6f4b0 |
Close
Hashes for simple_multiprocessing-0.0.9-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | f5bb1ca3e47f96c26440f812cdf9f17142100a05c8fa573534f4dfa5feed8a28 |
|
MD5 | af761b34cc37cb571126b3cb2864faa6 |
|
BLAKE2b-256 | 8252e45b1d774c25cd2142ea6c1ba195ea927f1e65387e3b7f955cb016ae8507 |