Python - 正确杀死/退出期货线程？

Question

我之前使用的是threading.Thread 模块。现在我使用concurrent.futures -> ThreadPoolExecutor。以前，我使用以下代码来退出/杀死/结束一个线程：

def terminate_thread(thread):
    """Terminates a python thread from another thread.

    :param thread: a threading.Thread instance
    """
    if not thread.isAlive():
        return

    exc = ctypes.py_object(SystemExit)
    res = ctypes.pythonapi.PyThreadState_SetAsyncExc(
        ctypes.c_long(thread.ident), exc)
    if res == 0:
        raise ValueError("nonexistent thread id")
    elif res > 1:
        # """if it returns a number greater than one, you're in trouble,
        # and you should call it again with exc=NULL to revert the effect"""
        ctypes.pythonapi.PyThreadState_SetAsyncExc(thread.ident, None)
        raise SystemError("PyThreadState_SetAsyncExc failed")

这似乎不适用于期货界面。这里的最佳做法是什么？只是return？我的线程正在控制 Selenium 实例。我需要确保当我杀死一个线程时，Selenium 实例被拆除。

编辑：我已经看到被引用为重复的帖子。这是不够的，因为当你冒险进入未来之类的事情时，行为可能会完全不同。在前面的threading模块的情况下，我的terminate_thread函数是可以接受的，不适用于其他q/a的批评。这与“杀戮”不同。请看一下我发布的代码。

我不想杀人。我想检查它是否还活着并以最合适的方式优雅地退出线程。期货怎么办？

Answer 1

如果你想让线程完成他们当前的工作使用：

thread_executor.shutdown(wait=True)

如果你想抨击当前正在运行的期货并停止所有 ...future...(heh) 期货使用：

thread_executor.shutdown(wait=False)
for t in thread_executor._threads:
    terminate_thread(t)

这使用您的 terminate_thread 函数在线程池执行程序的线程中调用异常。那些被打乱的 future 将返回异常集。

Answer 2

线程结果上的.cancel()怎么样？

cancel() 尝试取消呼叫。如果当前正在通话 已执行且无法取消，则该方法将返回 False， 否则调用将被取消，该方法将返回 True。

https://docs.python.org/3/library/concurrent.futures.html