1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
from easydev.multicore import MultiProcessing
def func(n=400, *args, **kargs):
"""A simple test function to play with MultiProcessing class
:param n: 400 takes about 5 seconds
"""
print("inside func", args, kargs)
import math
for i in range(0,n):
for j in range(0,n):
for k in range(0,n):
math.sqrt(float(i))
d = {'id':n}
return d
def test_func():
t = MultiProcessing(verbose=True)
t.add_job(func, 200)
t.add_job(func, 100)
t.add_job(func, 50)
t.run()
print(t.results)
|
