使用键盘中断关闭所有线程

Question

我在这里想要做的是使用键盘中断退出程序中所有正在进行的线程。这是创建线程的代码的精简版本：

for i in taskDictionary:
    try:
        sleep(60)
        thread = Thread(target = mainModule.executeThread)
        thread.start()
    except KeyboardInterrupt:
        thread.__stop()

程序本身要复杂得多，需要考虑大量影响线程的不同变量，甚至可以选择以顺序模式启动，在这种模式下，任务没有线程化，而是逐个启动，因此可能存在一些问题有了这个小的变化，我就想到了。我这样做的方式产生了50/50的结果。中断将起作用，但是线程将永远不会干净退出。有时他们会继续前进，但停止执行将来的线程，有时它们会退出有关中断的大量错误，而另一些时候，中断根本不会执行任何操作。上次我运行该程序时，该程序停止了将来任何线程的执行，但没有停止当前线程。是否有任何方法可以退出线程而无需进入线程实际在其中执行的模块？

Answer 1

类似的问题是“如何杀死线程？”

您在线程中创建退出处理程序，该处理程序由线程模块中的锁或事件对象控制。然后，您只需删除锁或向事件对象发出信号。这通知线程应该停止处理并正常退出。在你的主程序信号线后，剩下要做的唯一事情是使用thread.join()的方法main，这将等待线程关闭。

一个简短的例子：

import threading
import time

def timed_output(name, delay, run_event):
    while run_event.is_set():
        time.sleep(delay)
        print name,": New Message!"


def main():
    run_event = threading.Event()
    run_event.set()
    d1 = 1
    t1 = threading.Thread(target = timed_output, args = ("bob",d1,run_event))

    d2 = 2
    t2 = threading.Thread(target = timed_output, args = ("paul",d2,run_event))

    t1.start()
    time.sleep(.5)
    t2.start()

    try:
        while 1:
            time.sleep(.1)
    except KeyboardInterrupt:
        print "attempting to close threads. Max wait =",max(d1,d2)
        run_event.clear()
        t1.join()
        t2.join()
        print "threads successfully closed"

if __name__ == '__main__':
    main()

如果您确实需要 杀死
线程的功能，请使用多处理。它允许您将SIGTERM发送到各个“进程”（它也与线程模块非常相似）。一般而言，线程是针对您的IO绑定，而多处理则是针对您的处理器的绑定。