python多线程编程：如何优雅地关闭线程

您所在的位置：网站首页 › linux监控进程中的线程怎么删除掉记录 › python多线程编程：如何优雅地关闭线程

python多线程编程：如何优雅地关闭线程

2024-07-15 13:43| 来源: 网络整理| 查看: 265

在并发编程中，我们可能会创建新线程，并在其中运行任务，可能由于一些原因，决定停止该线程。例如：

不再需要线程任务的结果了。应用程序正在关闭。线程执行可能已经出现了异常

关于python多线程编程知识，请参阅由浅入深掌握Python多线程编程

Threading 模块的 Thread 类并没有提供关闭线程的方法。如果不正确关闭子线程，可能遇到如下问题：

中止主线程后，子线程仍然在运行，成为僵尸进程子线程打开的文件未能正确关闭，造成数据丢失子线程打开的数据库，未能提交更新，造成数据丢失

那么应该如何正确关闭线程呢？

1. Python 默认关闭线程的方式

线程对象创建后，调用start(方法运行，执行结束后，自动关闭。如下面的示例代码：

#!/usr/bin/python # -*- coding: UTF-8 -*- import threading #导入threading 模块 import time # 定义任务函数 print_time def print_time ( threadName ,delay ): count = 0 while count 0: print('T-minus', n) n -= 1 time.sleep(5) print("thread is ended") c = CountdownTask() th = Thread(target = c.run, args =(10, )) th.start() # 对于耗时线程，没必要再用join()方法了，注意主线程通常也需要有个监控循环 # … any code … # Signal termination q = input("please press any key to quit ") c.terminate() 2.1.2 关闭函数式线程

关闭函数式线程，可以用全局变量做状态变量

import threading import time def run(): while True: print('thread running') global stop_threads if stop_threads: break stop_threads = False t1 = threading.Thread(target = run) t1.start() time.sleep(1) stop_threads = True t1.join() print('thread killed') 2.2. 使用 threading.Event 对象关闭子线程 2.2.1 Event 机制工作原理

Event 是线程间通信的一种方式。其作用相当于1个全局flag，主线程通过控制 event 对象状态，来协调子线程步调。

使用方式

主线程创建 event 对象，并将其做为参数传给子线程主线程可以用set()方法将event 对象置为true, 用clear()方法将其置为false。子线程循环体内，检查 event 对象的值，如果为 True, 则退出循环。子线程，可使用 event.wait() 将阻塞当前子进程，直至event 对象被置为true.

event 类的常用方法

set() 设置 Trueclear() 设置 False,wait() 使进程等待，直到flag被改为true.is_set() 查询 event 对象，如被设置为真，则返回True, 否则返回False. if event.is_set(): # do something before end worker break

这种方式的优点是，Event对象是线程安全的，而且速度更快，推荐使用这种方式关闭耗时线程。

2.2.2 完整代码： from time import sleep from threading import Thread from threading import Event # define task function def task(event): # execute a task in a loop for i in range(100): # block for a moment sleep(1) # check for stop if event.is_set(): # 在此添加退出前要做的工作，如保存文件等 break # report a message print('Worker thread running...') print('Worker is ended') # create the event event = Event() # create a thread thread = Thread(target=task, args=(event,)) # start the new thread thread.start() # block for a while sleep(3) # stop the worker thread print('Main stopping thread') event.set() # 这里是为了演示，实际开发时，主进程有事件循环，耗时函数不需要调用join()方法 thread.join()

子线程执行其任务循环，它每次循环都会检查event对象，该对象保持 false，就不会触发线程停止。

当主线程调用event对象的 set() 方法后，在子线程循环体内，调用event对象is_set()方法，发现event 对象为True后, 立即退出任务循环，结束运行。

延伸阅读： python多线程编程: 如何暴力但不失优雅地关闭线程

【本文地址】

python多线程编程：如何优雅地关闭线程

python多线程编程：如何优雅地关闭线程

今日新闻

推荐新闻