In [2]:

    

from joblib import Parallel, delayed
import math,sys,time

def square_int(n):
    return sum([x for x in range (1,n)])


    

In [3]:

    

results = []
for i in range(1000,1010):
    results.append(square_int(i))
print results


    

    




[499500, 500500, 501501, 502503, 503506, 504510, 505515, 506521, 507528, 508536]

In [12]:

    

from joblib import Parallel, delayed

start_time = time.time()
results = []
results = Parallel(n_jobs= -1, backend="threading")(delayed(square_int)(n) for n in range(10000000,10000010))
                                                                                          
print results
print "Time elapsed: ", time.time() - start_time, "s"


    

    




[49999995000000, 50000005000000, 50000015000001, 50000025000003, 50000035000006, 50000045000010, 50000055000015, 50000065000021, 50000075000028, 50000085000036]
Time elapsed:  21.8465940952 s

In [11]:

    

from joblib import Parallel, delayed

start_time = time.time()
results = []
#results = Parallel(n_jobs= -1, backend="multiprocessing")(delayed(square_int)(n) for n in range(10000000,10000010))
results = Parallel(n_jobs= -1, backend="multiprocessing")(delayed(square_int)(n) for n in range(10000000,10000010))

print results
print "Time elapsed: ", time.time() - start_time, "s"


    

    




[49999995000000, 50000005000000, 50000015000001, 50000025000003, 50000035000006, 50000045000010, 50000055000015, 50000065000021, 50000075000028, 50000085000036]
Time elapsed:  5.18976211548 s

In [ ]: