VeighNa · 第 2 章 EventEngine 事件引擎

VeighNa · 第 2 章 EventEngine 事件引擎

章节摘要:本章精读 VeighNa 的框架心脏——vnpy/event/engine.py(全文件仅 145 行)。EventEngine 是一个基于 Queue + Thread + 定时器的发布订阅事件总线:生产者(网关收到行情、策略发信号、定时器)把 Event 投进队列,消费者(一个后台线程)按事件 type 分发给订阅者。它的精妙在于用极简代码搭起了整个框架的数据流:每个 Tick/订单/成交都通过它流转,UI、OMS、策略各自订阅自己关心的事件 type。本章先拆 EventEngine 的初始化与生命周期,再讲 register/put/process 三大核心机制。本章共 2 节,前置依赖为第 1 章。

学习目标

阅读完本章,你应当能够:

1. 逐行读懂 engine.py 的 145 行源码。
2. 说清 EventEngine 的三件套:Queue / Thread / Timer。
3. 区分专属处理器(register)与通用处理器(register_general)。
4. 解释 _run 主循环为什么用 timeout=1 而不是无限阻塞。
5. 理解为什么 VeighNa 选 Queue+Thread 而非 asyncio。

核心概念速览

事件驱动的精髓:生产者只管 put,消费者只管 register,互不认识,靠事件 type 解耦。

子章节导航

01 EventEngine 的初始化与生命周期

Event/HandlerType 数据结构;__init__ 的六个私有成员;_run 主循环为什么 timeout=1;_run_timer 定时器线程;start/stop 生命周期;为什么不用 asyncio。

02 register/put/process 三大核心机制

put 投递事件;_process 两段式分发(专属 + 通用);register/unregister 专属处理器去重;register_general 通用处理器;EVENT_TIMER 心跳的用途。

子章节之间的逻辑关系

本章第 01 节(初始化/生命周期) ──► 第 02 节(注册/投递/分发机制)
                                          │
                                          ▼
                              下一章(第 3 章 数据建模体系)
​

前置知识与后续延伸

前置知识:

• 第 1 章(理解事件总线是装配的"通信层")
• Python 多线程基础(queue.Queue、threading.Thread、time.sleep)

后续延伸:

• 第 3 章讲 Event 的 data 载荷长什么样(dataclass 数据建模)
• 第 4 章讲 OmsEngine 怎么订阅事件维护状态缓存
• 第 5 章讲网关的 on_xxx 回调怎么 put 事件