Python 中断线程

在多线程编程中，根据某些条件中断线程的执行是一个常见的需求。在一个多线程程序中，新线程中的任务可能需要停止。这可能是由于多种原因，例如任务完成、应用程序关闭或其他外部条件。

在 Python 中，可以使用 threading.Event 或在线程内部设置一个终止标志来中断线程。这些方法允许你有效地中断线程，确保资源被正确释放并且线程干净地退出。

使用 Event 对象中断线程

使用 threading.Event 类来中断线程是最直接的方式之一。这个类允许一个线程向另一个线程发送信号，表明某个特定的事件已经发生。以下是如何使用 threading.Event 实现线程中断的方法。

示例

在这个例子中，我们有一个 MyThread 类。它的对象开始执行 run() 方法。主线程睡眠一定的时间后设置一个事件。直到检测到事件之前，run() 方法中的循环将继续运行。一旦事件被检测到，循环就会终止。

from time import sleep
from threading import Thread, Event

class MyThread(Thread):
    def __init__(self, event):
        super(MyThread, self).__init__()
        self.event = event

    def run(self):
        i = 0
        while True:
            i += 1
            print('子线程运行中...', i)
            sleep(0.5)
            if self.event.is_set():
                break
        print('子线程中断')

event = Event()
thread1 = MyThread(event)
thread1.start()

sleep(3)
print('主线程停止子线程')
event.set()
thread1.join()

当你执行这段代码时，它将产生以下输出：

子线程运行中... 1
子线程运行中... 2
子线程运行中... 3
子线程运行中... 4
子线程运行中... 5
子线程运行中... 6
主线程停止子线程
子线程中断

使用标志中断线程

另一种中断线程的方法是在线程定期检查的一个标志。这种方法涉及在线程对象中设置一个标志属性，并在执行循环中定期检查其值。

示例

这个例子展示了如何在 Python 多线程程序中使用一个标志来控制和停止一个运行中的线程。

import threading
import time

def foo():
    t = threading.current_thread()
    while getattr(t, "do_run", True):
        print("正在处理任务")
        time.sleep(1)
    print("一段时间后停止线程。")

# 创建一个线程
t = threading.Thread(target=foo)
t.start()

# 允许线程运行 5 秒钟
time.sleep(5)

# 设置终止标志来停止线程
t.do_run = False

当你执行这段代码时，它将产生以下输出：

正在处理任务
正在处理任务
正在处理任务
正在处理任务
正在处理任务
一段时间后停止线程。