Пул многопроцессорности внутри Время ожидания процесса

Question

Когда я использую следующий код, результат пула всегда возвращает тайм-аут, есть ли что-то логически неправильное, что я делаю?

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?

Answer 1

Вы не можете передавать объекты пула между процессами.

Если вы попробуете этот код, Python выдаст исключение: "NotImplementedError: объекты пула не могут быть переданы между процессами или засолены".

from multiprocessing import Queue, Pool

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

Поэтому, если вы хотите, чтобы ваш код работал, просто создайте объект Pool в методе add_wrap.

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()