Python主线程如何在超时后终止子线程并抛出异常？

Python的threading.Thread本身没有t.timeout(10)这种直接设置超时并自动终止线程的机制。因为Python线程采用协作式调度，无法强制终止正在运行的线程——强行终止可能导致资源泄漏（比如GDAL未释放的文件句柄），引发不可预测的问题。

推荐解决方案：使用concurrent.futures.ThreadPoolExecutor #

标准库的concurrent.futures模块提供了简洁的超时处理能力，能满足你的需求：

import osgeo.gdal as gdal
from concurrent.futures import ThreadPoolExecutor, TimeoutError

def open_gdal_file(filepath):
    return gdal.Open(filepath)

filepath = "http://.../test.tif"

# 创建单线程的线程池
with ThreadPoolExecutor(max_workers=1) as executor:
    # 提交打开文件的任务
    future_task = executor.submit(open_gdal_file, filepath)
    try:
        # 等待10秒获取结果，超时则抛出TimeoutError
        dataset = future_task.result(timeout=10)
        # 成功打开文件，后续可处理dataset
    except TimeoutError:
        # 捕获超时异常，转为你需要的RuntimeError抛出
        raise RuntimeError("打开文件超时，已终止操作")

说明 #

• future.result(timeout=10)会阻塞主线程，等待任务完成或超时。超时后直接抛出TimeoutError，你可以捕获后转换为业务需要的异常类型。
• 注意：超时后，执行gdal.Open的线程可能不会立即终止（因为无法强制中断C扩展的阻塞调用），但主线程可以正常继续执行，不会被卡住。

不推荐的原生线程方案 #

如果尝试用threading.Event配合原生线程实现超时，由于gdal.Open是底层阻塞调用，子线程无法在阻塞过程中检查超时标记，因此这种方案对GDAL的场景无效，不建议使用。

内容的提问来源于stack exchange，提问作者Bằng Rikimaru