python - 是否可以使用 multiprocessing.Event 为进程池实现同步屏障？

Question

是否可以使用 multiprocessing.Event 为进程池实现同步屏障？我正在使用 Python 2.7。但看起来事件没有在进程之间共享。我的代码有问题吗？

def test_func(event):
    event.wait()
    return datetime.datetime.now()

def log_result(result):
    result_list.append(result)

if __name__ == '__main__':
    pool_size=10
    pool = multiprocessing.Pool(processes=pool_size)
    event = multiprocessing.Manager().Event()
    for _ in xrange(pool_size):
        pool.apply_async(test_func, args=(event,), callback=log_result)
    pool.close()
    pool.join()   
    time.sleep(5)
    event.set()

Answer 1

你有死锁：pool.join() 等待启动的进程，所有进程都在 event.wait() 上等待。Sedd 池加入：

加入（）

Wait for the worker processes to exit

基本上你必须在“event.set()”之后移动“pool.join()”，一切都应该没问题。