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()
start / i
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.11.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 9031145a868bc57cc53989f8750ed9ca74b1de5591d5af636d86cb7b803db006 |
|
MD5 | 56954275237b3d8c29735767a51ac506 |
|
BLAKE2b-256 | 24119bacfc310c1a6402fdfdaf2973caecba42256332edfea1d61f6cb549e1b3 |
Close
Hashes for simple_multiprocessing-0.0.11-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | f787c5bc0dc7b4c00aabac3499c8e6ddc85276d6c2e879975526ed9581315479 |
|
MD5 | 058f7505ba9324291c1efb501274c594 |
|
BLAKE2b-256 | 52154e5b95ba225d2f2c7b370df923f0e63b8b1217d0c80e7dd9ade1dd537465 |