simple_multiprocessing
Project description
simple_multiprocessing
Description
Execute multiple async tasks (via multiprocessing.Process, or threading.Thread) 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_func(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
tasks = [Task(test_func, i) for i in range(5)]
# via threading
results_via_threading = MultiThread(tasks).solve(timeout=1)
for i, r in enumerate(results_via_threading):
print(i, type(r), r)
# via Multiproccess
results_via_multiprocess = MultiProcess(tasks).solve(timeout=1)
for i, r in enumerate(results_via_multiprocess):
print(i, type(r), r)
Dependencies
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.14.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | ed016ef75fed1bbb9b1b59086924b2b7d0f00c575700147bd8b39759df2dbe62 |
|
MD5 | e53fb995a4fbdd3c01d8cffec9130214 |
|
BLAKE2b-256 | a55653138e3c66044ba5e8353eed348c24823fc54f69098e4986893e6734deb6 |
Close
Hashes for simple_multiprocessing-0.0.14-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 7d3bbe47c57ba35f70b9a966abdc7973345fb8d9677191a1a31f0c90092ad364 |
|
MD5 | cc7444df59c69f32349c8d346dd6d374 |
|
BLAKE2b-256 | c0ceac43f0bca6feb46004af56ea674f89f3f77c121794f7d50e38edff40182e |