Advertisement
Guest User

Untitled

a guest
Sep 24th, 2019
93
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.59 KB | None | 0 0
  1. import multiprocessing as mp
  2. from time import sleep
  3. from random import random
  4.  
  5. def init(aa, vv):
  6. global a, v
  7. a = aa
  8. v = vv
  9.  
  10. def worker(i):
  11. print('Worker {} started'.format(i))
  12. sleep_time = random() * 10
  13. print('Worker {} going to sleep for {}'.format(i, sleep_time))
  14. sleep(sleep_time)
  15. a[i] = v.value * i
  16. print('Worker {} done'.format(i), v.value, a[:], v.value*i)
  17.  
  18. if __name__ == "__main__":
  19. N = 10
  20. a = mp.Array('i', [0]*N)
  21. v = mp.Value('i', 5)
  22. p = mp.Pool(processes=10, initializer=init, initargs=(a, v))
  23. p.map(worker, range(N))
  24. print(a[:])
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement