Обратный звонок не набирается

Question

for x,y in my_dict.iteritems(): 
    for z in y: 
      def done_callback(result): 

       code,content=result.get() 
       if code==0: 
         if content: 
          new_content.append(content) 
         else: 
          pass 
       else: 
         return error_html(environ,start_response,content) 


      try: 
        pool.apply_async(function_returns_tuple,(x,z,my_val),done_callback) 
      except Exception as e: 
        print e 

Когда я вижу значение new_content, он пуст, а также функция обратного вызова - done_callback не вызван. Я упускаю какую-то часть?

Answer 1

Вот рабочий минимальный пример:

from multiprocessing import Pool 
from time import sleep 

my_dict = { "a": [1, 2], "b": [3] } 
my_val = 5 

# has to be defined before Pool is created 
def processing_function(args): 
    (x, y, v) = args  # mapped function only gets one arg; so we unpack 
    if y == 2:   # we throw a wrinkle in, 
     return ('', '') # to demonstrate filter 
    return ("[Code %s %d %d]" % (x, y, v), "[Content %s %d %d]" % (x, y, v)) 


pool = Pool(2) # execute two workers in parallel (feel free to change) 

# make an iterator for all your values 
inputs = ((x, z, my_val) for (x, y) in my_dict.iteritems() for z in y) 
async_results = pool.map_async(processing_function, inputs) 
pool.close()  # necessary before pool.join() 
pool.join()  # wait for all processes in the pool to finish 
results = async_results.get() # now we can get the results 
# we can extract just the results we want... 
non_empty_content_joined = ''.join(
     content for (code, content) in results if content != '') 
print non_empty_content_joined 
# => [Content a 1 5][Content b 3 5] 

Answer 2

При указании функции обратного вызова в apply_async, обратный вызов будет вызван через некоторое время. «Асинхронная» часть означает, что вы можете продолжать работу в своем текущем потоке до завершения задания .

В вашем примере кода вы вызываете apply_async в цикле, но затем вы не ожидаете завершения каких-либо операций. Вам нужно будет поддерживать основной поток (например, путем блокировки или циклирования), если вы хотите дождаться завершения операций.