Многопроцессорный пул внутри Время обработки процесса

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

Я знаю this bug, и подумал бы, что она была бы зафиксирована в питон 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()