python多进程编程-多进程编程中的异常处理（二）

import multiprocessing
import time

def worker():
    for i in range(5):
        print(f"Process {multiprocessing.current_process().pid} is running")
        time.sleep(1)
    raise Exception("Process error")

def handle_result(result):
    if isinstance(result, Exception):
        print(f"Pool is raising {result}")

if __name__ == '__main__':
    pool = multiprocessing.Pool(2)
    try:
        pool.apply_async(worker, callback=handle_result)
        pool.apply_async(worker, callback=handle_result)
        pool.close()
        pool.join()
    except Exception as e:
        print(f"Main process is raising {e}")