python复习--进程相关--Event()

woo_test

695人浏览 · 2026-03-30 20:39:52

woo_test · 2026-03-30 20:39:52 发布

一、Event 是什么

Event 是 multiprocessing 提供的一种 进程间同步机制。

本质是一个 共享状态的信号标志。

可以把 Event 理解为一个 全局开关：

False → 未触发（默认状态）
True → 已触发

多个进程可以同时监听这个状态。

二、Event 常用方法

Event 提供了 4 个核心方法：

1. set()

触发事件，将状态设置为 True

event.set()

2. clear()

重置事件状态为 False

event.clear()

3. is_set()

检查事件当前状态

event.is_set()

返回值：True/False

4. wait(timeout=None)

阻塞等待事件触发。

如果事件已经是 True，会立即返回。

event.wait()

设置超时时间：

event.wait(timeout=5)

三、Event + Process 能解决什么问题

Event 常用于进程间通信（IPC）。

1. 典型用途：

进程同步
控制执行顺序
安全通知进程开始任务
安全通知进程停止任务

四、常见使用场景

场景	说明
启动信号	主进程通知子进程开始
停止信号	优雅终止子进程
多进程同步	等待某个条件达成
循环控制	根据 Event 状态运行

五、基本使用模式

1：主进程控制子进程启动

子进程等待 Event 信号。

示例

# ================= 标准库 =================
import time
from multiprocessing import Event, Process


def worker(start_event):
    """子进程任务"""
    print("子进程：等待启动信号...")
    # 阻塞等待事件触发
    start_event.wait()
    print("子进程：开始工作")
    time.sleep(2)
    print("子进程：工作完成")


if __name__ == "__main__":
    # 创建 Event，默认状态是 False（未触发）
    start_event = Event()
    # 创建子进程
    process = Process(target=worker, args=(start_event,))
    process.start()
    time.sleep(3)
    print("主进程：发送启动信号")
    # 触发事件
    start_event.set()
    process.join()

说明
wait() 会阻塞进程
set() 触发后，所有等待的进程都会继续执行

六、使用 Event 作为“停止信号”（最常见模式）

这是实际项目中最常用的模式。

子进程循环执行任务，收到停止信号后退出。

示例

python
# ================= 标准库 =================
import time
from multiprocessing import Event, Process


def worker(stop_event):
    """子进程循环任务"""
    while not stop_event.is_set():
        print("子进程：正在运行...")
        time.sleep(1)
    print("子进程：收到停止信号，退出")


if __name__ == "__main__":
    stop_event = Event()
    process = Process(target=worker, args=(stop_event,))
    process.start()
    time.sleep(5)
    print("主进程：通知停止")
    stop_event.set()
    process.join()

优点
相比 process.terminate()：

更安全
可以释放资源
可以保存状态

七、多个进程共享一个 Event

一个 Event 可以同时控制多个进程。

类似广播信号。

示例

# ================= 标准库 =================
import time
from multiprocessing import Event, Process


def worker(event, idx):
    print(f"进程 {idx} 等待信号")
    event.wait()
    print(f"进程 {idx} 开始执行")


if __name__ == "__main__":
    event = Event()
    processes = []
    for i in range(3):
        process = Process(target=worker, args=(event, i))
        process.start()
        processes.append(process)

    time.sleep(2)
    print("主进程：统一发出信号")
    event.set()
    for process in processes:
        process.join()