Python中挂起线程的终止方法求助

核心方案：让阻塞操作自身支持超时 #

最稳妥的方式是从根源解决——给会话创建的网络操作直接设置超时，避免线程长时间挂起：

• 若使用原生socket：调用socket.settimeout(seconds)设置超时时长，超时会抛出socket.timeout异常，线程捕获后即可自行退出。
• 若使用requests等HTTP库：在请求时指定timeout参数，比如requests.get(url, timeout=5)，超时会触发requests.exceptions.Timeout。
• 若为SSH类会话（如paramiko）：在connect方法中传入timeout参数，比如client.connect(host, timeout=5)，或创建客户端时全局设置超时。

替代方案：用进程替代线程实现强制终止 #

如果无法修改会话创建的超时逻辑，可以用multiprocessing进程替代线程——进程支持强制终止，适合处理这种无法响应中断的阻塞场景：

import multiprocessing
import time

def create_session(host):
    # 此处替换为你的会话创建逻辑
    time.sleep(60 if host == "bad_host" else 1)
    print(f"会话创建成功：{host}")

if __name__ == "__main__":
    hosts = ["host1", "host2", "bad_host"]
    timeout = 5
    processes = []

    for host in hosts:
        p = multiprocessing.Process(target=create_session, args=(host,))
        p.start()
        processes.append((p, host))

    # 逐个等待进程，超时则强制终止
    for p, host in processes:
        p.join(timeout)
        if p.is_alive():
            print(f"超时，强制终止{host}的进程")
            p.terminate()
            p.join()  # 等待进程彻底退出

线程池优化：过滤超时任务（仅优化主线程等待逻辑） #

如果坚持使用线程，可以用concurrent.futures.ThreadPoolExecutor结合wait方法，先处理已完成的任务，超时后主线程可先退出（但已启动的阻塞线程仍会继续运行，直到自身操作结束）：

from concurrent.futures import ThreadPoolExecutor, wait
import time

def create_session(host):
    time.sleep(60 if host == "bad_host" else 1)
    return f"会话创建成功：{host}"

if __name__ == "__main__":
    hosts = ["host1", "host2", "bad_host"]
    timeout = 5

    with ThreadPoolExecutor(max_workers=3) as executor:
        futures = {executor.submit(create_session, host): host for host in hosts}
        # 等待超时，获取已完成的任务
        done, not_done = wait(futures, timeout=timeout)
        
        # 处理已完成的任务
        for future in done:
            print(future.result())
        
        # 尝试取消未完成任务（仅对未启动的任务有效，已启动的无法取消）
        for future in not_done:
            print(f"放弃{futures[future]}的会话创建任务")
            future.cancel()

注意事项 #

• 避免强制终止线程：Python线程没有安全的强制终止机制，强制终止可能导致资源泄漏（如未关闭的网络连接）。
• 守护线程的风险：若将线程设为守护线程，主线程退出时会直接杀死守护线程，但可能导致会话创建过程中的资源无法正常释放，仅适合对资源泄漏不敏感的场景。

内容的提问来源于stack exchange，提问作者Uwe