ジェネレータ機能を持つPythonマルチプロセッシングモジュールを使用する際にエラーが発生しました。

Question

は、いくつかのいずれかを事前に

MaybeEncodingError Traceback (most recent call last) in() 5 p = Pool(2) 6 ----> 7 n = p.map(sq, range(10))

/home/devil/anaconda3/lib/python3.4/multiprocessing/pool.py in map(self, func, iterable, chunksize) 258 in a list that is returned. 259 ''' --> 260 return self._map_async(func, iterable, mapstar, chunksize).get() 261 262 def starmap(self, func, iterable, chunksize=None):

/home/devil/anaconda3/lib/python3.4/multiprocessing/pool.py in get(self, timeout) 606 return self._value 607 else: --> 608 raise self._value 609 610 def _set(self, i, obj):

MaybeEncodingError: Error sending result: '[, ]'. Reason: 'TypeError("can't pickle generator objects",)'

感謝

from multiprocessing import Pool 
def sq(x): 
    yield x**2 
p = Pool(2) 

n = p.map(sq, range(10)) 

私は取得していますエラー、次の以下のコードと間違っているものを説明してもらえます。

Answer 1

ファンクションではなく、ジェネレータを使用する必要があります。手段：yieldをreturnに変更してsqを関数に変換します。 Poolはジェネレータでは使用できません。

さらに、Windows上で動作するバージョンを作成しようとすると、私は奇妙な繰り返しのエラーメッセージが表示されました。

文字通り私が得たコメント、それは一目瞭然だから引用

Attempt to start a new process before the current process 
has finished its bootstrapping phase. 

This probably means that you are on Windows and you have 
forgotten to use the proper idiom in the main module: 

if __name__ == '__main__': 

：

the error on windows is because each process spawns a new python process which interprets the python file etc. so everything outside the "if main block" is executed again"

ので移植できるように、あなたはこのモジュールを実行するとき__name__=="__main__"を使用する必要があります。

from multiprocessing import Pool 

def sq(x): 
    return x**2 

if __name__=="__main__": 
    p = Pool(2) 
    n = p.map(sq, range(10)) 
    print(n) 

結果を：

[0, 1, 4, 9, 16, 25, 36, 49, 64, 81] 

編集：あなたが値を格納したくない場合は、事前にあなたは

n = p.imap(sq, range(10)) 

nimapは今ジェネレータオブジェクトで使用することができます。ドキュメントはimapがmap