类型错误而代表任意元素类型multiprocessing.Array

Question

>>> from multiprocessing import Array, Value 
>>> import numpy as np 
>>> a = [(i,[]) for i in range(3)] 
>>> a 
[(0, []), (1, []), (2, [])] 
>>> a[0][1].extend(np.array([1,2,3])) 
>>> a[1][1].extend(np.array([4,5])) 
>>> a[2][1].extend(np.array([6,7,8])) 
>>> a 
[(0, [1, 2, 3]), (1, [4, 5]), (2, [6, 7, 8])] 

继蟒多处理example: def test_sharedvalues():我尝试使用下面的代码创建一个共享的代理对象：

shared_a = [multiprocessing.Array(id, e) for id, e in a] 

，但它给我一个错误

Traceback (most recent call last): 
    File "<stdin>", line 1, in <module> 
    File "/usr/lib64/python2.6/multiprocessing/__init__.py", line 255, in Array 
    return Array(typecode_or_type, size_or_initializer, **kwds) 
    File "/usr/lib64/python2.6/multiprocessing/sharedctypes.py", line 87, in Array 
    obj = RawArray(typecode_or_type, size_or_initializer) 
    File "/usr/lib64/python2.6/multiprocessing/sharedctypes.py", line 60, in RawArray 
    result = _new_value(type_) 
    File "/usr/lib64/python2.6/multiprocessing/sharedctypes.py", line 36, in _new_value 
    size = ctypes.sizeof(type_) 
TypeError: this type has no size 

Answer 1

好的。问题是解决了

我改变

>>> a = [(i,[]) for i in range(3)] 

到

>>> a = [('i',[]) for i in range(3)] 

，这解决了类型错误。

事实上，我也发现，我并不一定必须使用i设定为在范围内计数（3）（因为阵列自动允许分度），则“i”是为下multiprocessing.sharedctypes c_int的类型代码

希望这有助于。