3. 事件驱动回测框架设计

事件驱动回测框架的核心思想是将回测过程建模为一系列离散事件的产生与消费。与向量化回测（一次性计算所有价格序列）不同，事件驱动架构更贴近真实交易环境，支持复杂的订单逻辑、滑点模型和异步数据流。本节从整体架构、事件循环、队列设计及模块解耦四个维度展开。

3.1 框架整体架构图

下图展示了事件驱动回测框架的四层架构：数据层、事件引擎层、策略层与执行层。各层通过统一的事件队列进行通信，实现完全的模块解耦。

3.2 事件循环机制

事件循环是框架的心脏，它按照时间顺序从事件队列中取出事件并分发给对应的处理器。核心流程如下：

1. 初始化：加载历史数据、初始化策略与组合、启动事件队列。
2. 时间推进：按最小时间粒度（如 1 分钟或 1 天）推进回测时钟。
3. 数据注入：将当前时间片的数据包装为 MarketEvent 推入队列。
4. 事件处理：循环从队列头部取出事件，根据事件类型调用对应的处理函数。
5. 状态更新：处理完所有当前时间片的事件后，更新组合净值与绩效指标。
6. 终止条件：所有时间片处理完毕或触发强制终止条件。

3.3 事件队列的设计原则

事件队列是框架的通信总线，其设计直接影响回测的确定性、性能与可扩展性。以下是核心设计原则：

• FIFO 为主，优先级为辅：同一时间片内的事件按先进先出处理；跨时间片的事件按时间戳排序。可引入优先级队列处理紧急事件（如强制平仓）。
• 无锁设计：单线程回测中避免使用线程锁，通过队列的原子操作保证事件顺序。
• 事件不可变：事件一旦入队，其属性不可修改。如需更新状态，应生成新事件而非修改旧事件。
• 容量预分配：根据回测周期与数据量预估队列容量，避免频繁扩容带来的性能损耗。
• 序列化友好：事件对象应支持序列化/反序列化，便于断点续测与灰度回放。

3.4 模块解耦思想

事件驱动架构的核心优势在于模块间的松耦合。每个模块只依赖事件接口，不依赖具体实现。以下是解耦的具体实践：

解耦带来的直接收益是可测试性与可扩展性的大幅提升。在灰度发布场景中，可以只替换执行模块为真实交易接口，而数据、策略、组合模块完全复用回测代码，实现从回测到实盘的无缝过渡。

# 事件驱动框架核心接口示例
class Event:
    def __init__(self, event_type: str, timestamp: datetime, data: dict):
        self.type = event_type
        self.timestamp = timestamp
        self.data = data

class EventQueue:
    def __init__(self):
        self._queue = []  # 主队列
        self._priority_queue = []  # 优先级队列

    def push(self, event: Event, priority: int = 0):
        if priority > 0:
            heapq.heappush(self._priority_queue, (priority, event))
        else:
            self._queue.append(event)

    def pop(self) -> Event:
        if self._priority_queue:
            return heapq.heappop(self._priority_queue)[1]
        return self._queue.pop(0) if self._queue else None

class EventLoop:
    def __init__(self, queue: EventQueue):
        self.queue = queue
        self.handlers = {}  # event_type -> handler

    def register_handler(self, event_type: str, handler):
        self.handlers[event_type] = handler

    def run(self):
        while True:
            event = self.queue.pop()
            if event is None:
                break
            handler = self.handlers.get(event.type)
            if handler:
                handler(event)