Keyboardinterrupt 不会停止线程以继续在 python 中运行

Question

这段代码运行良好，我唯一的问题是当我需要停止我的代码时，我输入 ctrl+c 尽管给出：

for thread in threads:
    thread.alive = False
    thread.join()
    sys.exit(e)

在代码中，线程继续运行，说线程必须下载，即使在keyinterrupt之后它仍然继续下载。如何优雅地退出代码？

这是完整的代码：

 try:
    threads = []
    while len(list1) != 0:
        while len(threads) != 4:
            time.sleep(1)
            item = list1.pop(0)
            thread = threading.Thread(target=func, args=(item, ))
            threads.append(thread)
            thread.start()
        for thread in threads:
            thread.join()
        for thread in threads:
            if not thread.is_alive():
                # get results from thread
                threads.remove(thread)
        if len(list1) == 0:
            logging.error("Nothing")
            sys.exit(1)
except KeyboardInterrupt as e:
    logging.error("Keyboard Interruption, code exiting!!")
    list1.append(item)
    logging.info(f'{item} Adding back to the list')
    # whenever there is a keyboard interrupt kill all the threads
    for thread in threads:
        thread.alive = False
        thread.join()
        sys.exit(e)
except Exception as e:
    logging.exception(f'Failed to initiate the threads : {e}')
    sys.exit(1)

Answer 1

除非线程真正关心标志，否则设置thread.alive = False 不会做任何事情。如果你想优雅地终止，你需要修改你的目标func，定期检查alive的值，如果是False就停止运行。

或者，如果您不关心正常关闭并且只希望所有线程在主线程退出时退出，您可以在创建它们时将daemon=True 添加到 Thread 构造函数中。

Answer 2

我认为你需要找到一种方法来杀死一个线程。这通常是不可取的，尤其是当线程正在读取/写入文件时，或者当线程正在处理其他线程时。我建议阅读this post 了解更多详情。

您可以创建自定义线程包装器来安全地处理停止线程，或者如果您使用multiprocessing 库，您可以调用process.terminate()。