QMT 策略生命周期管理：利用 stop(ContextInfo) 优雅释放多线程与外部连接

在编写复杂的 QMT 量化交易策略时，我们经常会用到 Python 的多线程（threading）来处理异步任务（如实时监控舆情、接收外部 Webhook 信号、高频写入数据库等）。然而，如果策略被用户手动停止或因异常退出，而子线程没有被正确关闭，就会导致**孤儿线程（Zombie Threads）**继续占用系统资源，甚至引发内存泄漏或端口冲突。

QMT 平台提供了 stop(ContextInfo) 回调函数，专门用于在策略模型关闭停止前执行清理工作。本文将详细介绍如何利用该函数优雅地关闭子线程并释放外部连接。

1. 什么是 stop(ContextInfo) 函数？

在 QMT 的 Python 策略中，除了必须实现的 init(ContextInfo) 和 handlebar(ContextInfo) 之外，stop(ContextInfo) 是一个可选的生命周期函数：

• 触发时机：当用户在客户端点击“停止运行”策略，或者策略回测/运行结束时，C++ 底层框架会在彻底销毁 Python 解释器前，最后调用一次 stop 函数。
• 核心作用：用于回收资源。例如停止用户自建的子线程、关闭数据库连接（MySQL/MongoDB）、断开 Socket 连接、保存本地缓存数据等。

2. 优雅关闭子线程的设计模式

在 Python 中，我们不能强行杀死（kill）一个正在运行的线程。标准的优雅退出方式是使用信号标志位（如 threading.Event）。子线程在循环中定期检查该标志位，一旦发现退出信号，则主动结束循环并退出。

核心步骤：

1. 在 init 中初始化一个 threading.Event() 退出信号，并启动子线程。
2. 子线程的 run 循环中，使用 is_set() 检查退出状态。
3. 在 stop 函数中，调用 event.set() 发送退出信号，并使用 thread.join() 等待子线程安全结束。

3. 完整 Python 代码示例

以下是一个在 QMT 中安全启动和关闭子线程的完整策略模板：

#coding:gbk
import threading
import time

# 定义一个子线程任务
def background_task(exit_event):
    print("【子线程】后台监控线程已启动...")
    while not exit_event.is_set():
        # 模拟后台异步任务，如轮询外部数据或监控连接
        print("【子线程】正在读取外部数据源...")
        # 使用 exit_event.wait(timeout) 代替 time.sleep()，这样能保证收到退出信号时立即可响应
        exit_event.wait(timeout=2.0) 
    print("【子线程】接收到退出信号，正在安全释放资源并退出...")

def init(ContextInfo):
    print("【策略生命周期】init 初始化开始")
    
    # 1. 创建线程退出信号事件
    ContextInfo.exit_event = threading.Event()
    
    # 2. 创建并启动子线程
    ContextInfo.my_thread = threading.Thread(
        target=background_task, 
        args=(ContextInfo.exit_event,)
    )
    # 设置为守护线程，确保主程序异常时不会锁死
    ContextInfo.my_thread.daemon = True 
    ContextInfo.my_thread.start()
    
    print("【策略生命周期】子线程启动成功")

def handlebar(ContextInfo):
    # 策略主逻辑
    pass

def stop(ContextInfo):
    """
    QMT 策略停止前运行的清理函数
    """
    print("【策略生命周期】stop 触发：策略正在关闭，开始清理资源...")
    
    # 1. 触发退出信号
    if hasattr(ContextInfo, 'exit_event'):
        ContextInfo.exit_event.set()
        print("【策略生命周期】已向子线程发送退出信号")
    
    # 2. 等待子线程安全结束（避免主线程直接退出导致资源未释放完毕）
    if hasattr(ContextInfo, 'my_thread') and ContextInfo.my_thread.is_alive():
        ContextInfo.my_thread.join(timeout=5.0) # 最多等待5秒
        if ContextInfo.my_thread.is_alive():
            print("【警告】子线程未能在规定时间内退出！")
        else:
            print("【策略生命周期】子线程已安全关闭")
            
    print("【策略生命周期】清理工作完成，策略安全停止。")

4. 最佳实践与注意事项

1. 避免在子线程中调用 QMT 交易接口：QMT 的交易函数（如 passorder）和数据获取接口（如 get_market_data）通常是线程不安全的，必须在主线程（即 handlebar 或定时器回调中）调用。子线程应只负责外部数据接收、计算或日志记录，并通过队列（queue.Queue）将结果传回主线程。
2. 使用 Event.wait() 代替 time.sleep()：在子线程循环中，如果使用 time.sleep(10)，当策略停止时，子线程可能需要等待足足10秒才能响应退出信号。改用 exit_event.wait(10) 可以在收到信号时瞬间唤醒并退出。
3. 设置 daemon=True：将子线程设置为守护线程（Daemon Thread）是一层双保险，确保在极端情况下（如 stop 函数因其他错误崩溃），Python 解释器仍能强制退出，不会导致 QMT 客户端卡死。