20

メイン プロセスから multiprocessing.Process インスタンスによって書き込まれた文字列を読み取る必要があります。私はすでにマネージャーとキューを使用して引数をプロセスに渡しているため、マネージャーの使用は明らかですが、マネージャーは文字列をサポートしていません。

Manager() によって返されるマネージャーは、list、dict、Namespace、Lock、RLock、Semaphore、BoundedSemaphore、Condition、Event、Queue、Value、および Array の型をサポートします。

マルチプロセッシング モジュールのマネージャーを使用して、文字列で表される状態を共有するにはどうすればよいですか?

4

2 に答える 2

27

multiprocessing の Manager は、 ctypes モジュールからc_char_p型のインスタンスを保持できるValuesを保持できます。

>>> import multiprocessing
>>> import ctypes
>>> v = multiprocessing.Value('c', "Hello, World!")
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/usr/lib/python2.7/multiprocessing/__init__.py", line 253, in Value
    return Value(typecode_or_type, *args, **kwds)
  File "/usr/lib/python2.7/multiprocessing/sharedctypes.py", line 99, in Value
    obj = RawValue(typecode_or_type, *args)
  File "/usr/lib/python2.7/multiprocessing/sharedctypes.py", line 73, in RawValue
    obj.__init__(*args)
TypeError: one character string expected
>>> cstring = multiprocessing.Value(ctypes.c_char_p, "Hello, World!")
>>> cstring
<Synchronized wrapper for c_char_p(166841564)>
>>> cstring.value
'Hello, World!'

Python 3 の場合、 c_char_p の代わりに c_wchar_p を使用します。

参照：見つけるのに苦労した元の解決策を投稿してください。

したがって、マネージャーを使用して、次のように Python の複数のプロセスの下で文字列を共有できます。

>>> from multiprocessing import Process, Manager, Value
>>> from ctypes import c_char_p
>>> 
>>> def greet(string):
>>>     string.value = string.value + ", World!"
>>> 
>>> if __name__ == '__main__':
>>>     manager = Manager()
>>>     string = manager.Value(c_char_p, "Hello")
>>>     process = Process(target=greet, args=(string,))
>>>     process.start()
>>>     process.join()    
>>>     print string.value
'Hello, World!'
于 2014-01-22T18:25:44.243 に答える