Python多线程编程中如何正确结束线程？

对这个多线程如何结束子线程有不理解的地方，请前辈们指点，非常感谢！如下：
data=[]
def get(url):
if re.search(‘满足条件’,s,re.S):
data.append(url)

用 4 线程启动上面的函数，当这 4 线程同时运行的时候，只要其中一个线程满足了条件，就把数据添加到全局 data 里去，其他线程则马上结束，以避免修改 data 的数据，请问该如何使用 threading 模块或者 multiprocessing.dummy 模块呢？迷惑了一些时间，请指点，非常感谢
Python多线程编程中如何正确结束线程？


13 回复

用一个 flag 做消息同步就行了


在Python多线程里，想优雅地结束线程，最靠谱的方法是用threading.Event或者共享变量来发信号。别用那个Thread.stop()，它已经被废弃了，强行终止会引发资源没释放的问题。

核心思路是：在线程的主循环里，定期检查一个“停止标志”。主线程设置这个标志，子线程看到标志就自己安全退出。

下面是个完整例子：

import threading
import time

class StoppableThread(threading.Thread):
    def __init__(self):
        super().__init__()
        self._stop_event = threading.Event() # 创建一个事件对象作为停止标志

    def stop(self):
        """请求线程停止"""
        self._stop_event.set()

    def stopped(self):
        """检查是否收到停止请求"""
        return self._stop_event.is_set()

    def run(self):
        # 线程的主工作逻辑
        while not self.stopped():
            print(f"线程 {threading.current_thread().name} 正在运行...")
            time.sleep(1) # 模拟工作
        print(f"线程 {threading.current_thread().name} 正在清理并退出...")
        # 这里可以执行一些清理操作

# 使用示例
if __name__ == "__main__":
    thread = StoppableThread()
    thread.start()

    time.sleep(3) # 让子线程跑3秒

    print("主线程请求停止子线程...")
    thread.stop() # 发送停止信号
    thread.join() # 等待子线程真正结束
    print("子线程已结束。")

关键点：

  1. stop()方法只是设置事件标志，并不强制中断。
  2. 子线程在run()方法的循环里，每次迭代都检查stopped()。收到信号后，它会完成当前循环（或到达一个安全点），然后执行必要的清理，最后自然退出循环，线程结束。
  3. 主线程调用join()确保等待子线程完成退出。

对于需要阻塞在I/O操作（如socket.recv()）的线程，你需要结合超时机制来定期检查停止标志。比如把socket.settimeout()设个短时间，在超时异常里检查标志。

简单说，就是发信号让线程自己停，别硬来。

感谢你的回复，我的意思是只要其中一个线程添加数据到了全局 data 里面，其他线程立即结束，用 flag 能实现吗？

我猜楼上的意思是你每次 data.append(url) 都检测一个全局 flag 状态

你这种情况是 4 个线程对同一个 url 处理才会这样的吧。非要这样的话就和楼上一样用 flag 吧

Python 的 threading 模块没有提供强制终止其他线程的功能，正确的做法是线程检查一个标志位，然后自行退出。全局的 data 明显是一个共享变量，操作和访问它需要加锁啊，线程进入临界区的时候再检查不就好了？

如果你一定想要干掉其他线程的话（不推荐这样做），那么用 ctypes 调用 API 强杀吧，Win 下用 TerminateThread，Linux 下用 pthread_cancel，我没试过这样做，总感觉会搞出问题的样子

用 flag 可以实现吧，在其他线程填入数据之前判断一下 flag 的状态，如果已经填入就结束线程。

用异步 io

Python 有 GIL，应该不用加锁吧

append
原子操作不用加锁




PyList_Append 是在 GIL 里面操作的，但是不可能只向里面加数据，不访问它吧，不然共享的变量要来何用？

就楼主的业务逻辑,拿数据用 pop 就行,也不用锁
当然了,还是推荐自带锁的 deque

如果只是 append/pop 简单的内容，的确不需要锁，基本上是线程安全的。不过如果其它线程要主动判断data是否有数据，以便于决定是不是要自行终止的话，就需要加锁了，因为if data: pass，if 判断再执行这种操作不是线程安全的。

deque 本身不带锁，带锁的 deque 就是 Queue，如果从实现上来说的话。

仔细想想，我以前写的 Python 多线程代码好像有点过度加锁了，如果对 list 的操作足够简单，并且确保线程安全的话，可以不用加锁的。不过总感觉加锁比较安全。

另外，这个案例其实比较适合 asyncio。

回到顶部