我想在共享内存中使用numpy数组,以便与多处理模块一起使用。困难之处在于将其用作numpy数组,而不仅仅是ctypes数组。
from multiprocessing import Process, Array
import scipy
def f(a):
a[0] = -a[0]
if __name__ == '__main__':
# Create the array
N = int(10)
unshared_arr = scipy.rand(N)
arr = Array('d', unshared_arr)
print "Originally, the first two elements of arr = %s"%(arr[:2])
# Create, start, and finish the child processes
p = Process(target=f, args=(arr,))
p.start()
p.join()
# Printing out the changed values
print "Now, the first two elements of arr = %s"%arr[:2]
这会产生如下输出:
Originally, the first two elements of arr = [0.3518653236697369, 0.517794725524976]
Now, the first two elements of arr = [-0.3518653236697369, 0.517794725524976]
可以以ctype方式访问数组,例如arr[i]
是有意义的。但是,它不是numpy数组,并且我不能执行诸如-1*arr
或arr.sum()
之类的操作。我认为一个解决方案是将ctypes数组转换为numpy数组。然而(除了不能让它工作之外),我不相信它会再被分享。
似乎有一个标准的解决方案来解决这个普遍存在的问题。
https://stackoverflow.com/questions/7894791
复制相似问题