爲什麼Python中沒有報告多處理的錯誤，以及如何打開報告錯誤？

Question

我設置了一些簡單的代碼來測試多處理的一些問題處理，並且我無法跟蹤此代碼中的錯誤，因爲沒有來自進程的反饋。我怎麼能從子流程中接收異常，因爲現在我對它不知情。如何調試此代碼。

# coding=utf-8 
import multiprocessing 
import multiprocessing.managers 
import logging 

def callback(result): 
    print multiprocessing.current_process().name, 'callback', result 

def worker(io_lock, value): 
    # error 
    raise RuntimeError() 
    result = value + 1 
    with io_lock: 
    print multiprocessing.current_process().name, value, result 
    return result 

def main(): 
    manager = multiprocessing.Manager() 
    io_lock = manager.Lock() 
    pool = multiprocessing.Pool(multiprocessing.cpu_count()) 
    for i in range(10): 
    print pool.apply_async(worker, args=(io_lock, i), callback = callback) 
    pool.close() 
    pool.join() 

if __name__ == '__main__': 
    logging.basicConfig(level = logging.DEBUG) 
    main() 

Answer 1

您可以嘗試，捕獲和記錄工作進程內發生的異常。像這樣的東西

def worker(io_lock, value): 
    try: 
     raise RuntimeError('URGH') # Or do your actual work here 
    except: 
     logging.exception('Exception occurred: ') 
     raise # Re-raise the exception so that the process exits 

異常日誌處理程序將自動包含堆棧跟蹤。