Last commit for code/multiprocessing_shared_array.py: 46c764dcffa6c96c359a507d8351f2456e7af57f

IHPCSS2019 version

Ramses van Zonm [2019-07-08 00:55:50]
IHPCSS2019 version
# multiprocessing-shared-array.py
from numpy import arange
from multiprocessing import Process,Array
def myfunc(a, i):
  a[i] = -a[i]
arr = Array('d', arange(10.))
procs = []
for i in range(10):
  p = Process(target = myfunc, args = (arr, i))
  procs.append(p)
  p.start()
for proc in procs:
  proc.join()
print arr[:]
ViewGit