Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import multiprocessing as mp
- from time import sleep
- from random import random
- def init(aa, vv):
- global a, v
- a = aa
- v = vv
- def worker(i):
- print('Worker {} started'.format(i))
- sleep_time = random() * 10
- print('Worker {} going to sleep for {}'.format(i, sleep_time))
- sleep(sleep_time)
- a[i] = v.value * i
- print('Worker {} done'.format(i), v.value, a[:], v.value*i)
- if __name__ == "__main__":
- N = 10
- a = mp.Array('i', [0]*N)
- v = mp.Value('i', 5)
- p = mp.Pool(processes=10, initializer=init, initargs=(a, v))
- p.map(worker, range(N))
- print(a[:])
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement