3

我在这个网站的某个地方找到了以下示例：

import multiprocessing
import ctypes
import numpy as np

shared_array_base = multiprocessing.Array(ctypes.c_double, 10*10)
shared_array = np.ctypeslib.as_array(shared_array_base.get_obj())
shared_array = shared_array.reshape(10, 10)

# No copy was made
assert shared_array.base.base is shared_array_base.get_obj()

# Parallel processing
def my_func(i, def_param=shared_array):
    shared_array[i,:] = i

if __name__ == '__main__':
    pool = multiprocessing.Pool(processes=4)
    pool.map(my_func, range(10))

    print shared_array

上面的代码工作正常，但如果我想将一个数组添加到共享数组中，比如 shared_array += some_other_array （而不是上面的 shared_array[i,;] = i）我得到

分配前引用的局部变量“shared_array”

任何想法为什么我不能这样做？

4

1 回答 1

6

如果将变量分配给函数中的任何位置，则将其视为局部变量。 shared_array += some_other_array相当于shared_array = shared_array + some_other_array。因此shared_array被视为局部变量，在您尝试在赋值右侧使用它时不存在。

如果要使用全局shared_array变量，则需要通过global shared_array在函数中放入 a 来将其显式标记为全局变量。

您看不到错误的原因shared_array[i,:] = i是 this 没有分配给变量shared_array。相反，它改变了该对象，分配给它的一部分。在 Python 中，分配给一个裸名（例如，shared_array = ...）与任何其他类型的分配（例如，）非常不同shared_array[...] = ...，尽管它们看起来很相似。

请注意，顺便说一下，该错误与多处理无关。

于 2012-07-11T22:40:35.320 回答