在python的多进程模块中，如何找到哪个工作进程已经执行了该作业

Question

有什么方法可以找出Pool中的哪个工作进程已经执行了一个特定的工作。

例如，

def start_exe(): 
    #execute some bunch of statements 

if __name__ == '__main__': 
    p = Pool(5) 
    result = p.apply.async(start_exe) 
    print result.get() 

Answer 1

我没有看到任何的API，但你可以嵌入在结果做了工作流程的名称：

from multiprocessing import Pool, current_process 

def start_exe(): 
    return 'done', current_process().name 

if __name__ == '__main__': 
    p = Pool(5) 
    result = p.apply_async(start_exe) 

    print result.get() 

输出示例：

('done', 'PoolWorker-4')