Python中使用Event()实现多进程同步和通信

在Python中，我们可以使用Event来实现多进程间的同步和通信。Event是一个线程同步对象，它主要用于线程间的事件通知，一个线程可以通过wait()方法等待事件的发生，而另一个线程则通过set()方法来设置事件的发生。在多进程环境中，Event也可以用于进程间的事件通知和同步。

下面是一个使用Event实现多进程同步和通信的示例：

import multiprocessing

def worker1(event, data):
    print('Worker 1 is waiting for event...')
    event.wait()  # 等待事件发生
    print('Worker 1 received data:', data)

def worker2(event, data):
    print('Worker 2 is waiting for event...')
    event.wait()  # 等待事件发生
    print('Worker 2 received data:', data)

if __name__ == '__main__':
    event = multiprocessing.Event()  # 创建一个Event对象
    
    p1 = multiprocessing.Process(target=worker1, args=(event, 'Hello from Worker 1'))
    p2 = multiprocessing.Process(target=worker2, args=(event, 'Hello from Worker 2'))

    p1.start()
    p2.start()
    
    # 主进程等待一段时间后处理数据
    print('Main process is doing something...')
    event.set()  # 设置事件发生
    # event.clear()  # 清除事件状态
    
    p1.join()
    p2.join()

在上面的示例中，我们创建了两个子进程p1和p2，它们执行的函数分别是worker1和worker2。这两个函数都接受一个event参数和一个data参数。

在子进程中，首先调用event.wait()方法等待事件的发生。而在主进程中，我们通过调用event.set()方法来设置事件的发生。当事件发生后，子进程就会继续执行，并打印出接收到的数据。

需要注意的是，event对象在创建时会有一个初始状态，可以是已经设置了事件状态（即事件已经发生），也可以是还未设置事件状态（即事件还未发生）。当一个进程调用了event.set()方法后，事件的状态就被设置为已发生；而调用event.clear()方法则会将事件的状态清除为未发生。

通过使用Event对象，我们可以实现多进程之间的同步与通信，在某个进程需要等待其他进程完成某个动作时，可以将其阻塞，直到事件发生才继续执行。