3

次のコードを使用すると、プールの結果は常にタイムアウトを返しますが、論理的に間違っていることはありますか?

from multiprocessing import Pool, Process, cpu_count

def add(num):
  return num+1

def add_wrap(num):
  new_num = ppool.apply_async(add, [num])
  print new_num.get(timeout=3)

ppool = Pool(processes=cpu_count() )

test = Process(target=add_wrap, args=(5,)).start()

私はこのバグを認識しており、python 2.6.4 で修正されていると思っていたでしょうか?

4

1 に答える 1

2

プロセス間で Pool オブジェクトを渡すことはできません。

このコードを試すと、Python は例外を発生させます。

from multiprocessing import Queue, Pool

q = Queue()
ppool = Pool(processes=2)                                                       
q.put([ppool])
ppool = q.get()

したがって、コードを機能させたい場合は、 add_wrap メソッドで Pool オブジェクトを作成するだけです。

from multiprocessing import Pool, Process, cpu_count

def add(num):
  return num+1

def add_wrap(num):
  ppool = Pool(processes=cpu_count() )
  new_num = ppool.apply_async(add, [num])
  print new_num.get(timeout=3)

test = Process(target=add_wrap, args=(5,)).start()
于 2009-11-17T11:49:40.527 に答える