Advertisement
DeaD_EyE

multiprocessing with Pool using different functions...

Jul 19th, 2016
190
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 0.51 KB | None | 0 0
  1. from time import sleep
  2. from multiprocessing import Pool
  3.  
  4.  
  5. def func1(data):
  6.     sleep(4)
  7.     print('Func1 done')
  8.     return 42
  9.  
  10. def func2(data):
  11.     sleep(3)
  12.     print('Func2 done')
  13.     return 13
  14.  
  15. def func3(data):
  16.     sleep(2)
  17.     print('Func3 done')
  18.     return 21
  19.  
  20. functions = [func1, func2, func3]
  21.  
  22. data = [1,2,3,4]
  23.  
  24. def worker(args):
  25.     func, data = args
  26.     return func(data)
  27.  
  28.  
  29. work_to_do = [(f, data) for f in functions]
  30. pool = Pool(2)
  31. result = pool.map(worker, work_to_do)
  32.  
  33. print(result)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement