0
  • 聊天消息
  • 系统消息
  • 评论与回复
登录后你可以
  • 下载海量资料
  • 学习在线课程
  • 观看威廉希尔官方网站 视频
  • 写文章/发帖/加入社区
会员中心
创作中心

完善资料让更多小伙伴认识你,还能领取20积分哦,立即完善>

3天内不再提示

在Python中用于终止线程的两个选项

马哥Linux运维 来源:Escape 作者:Escape 2021-11-17 10:02 次阅读

我经常被问到如何杀死一个后台线程,这个问题的答案让很多人不开心: 线程是杀不死的。在本文中,我将向您展示Python中用于终止线程的两个选项。

如果我们是一个好奇宝宝的话,可能会遇到这样一个问题,就是:如何杀死一个Python的后台线程呢?我们可能尝试解决这个问题,却发现线程是杀不死的。而本文中将展示,在Python中用于终止线程的两个方式。

1. 线程无法结束

A Threaded Example

  • 下面是一个简单的,多线程的示例代码。

import randomimport threadingimport time
def bg_thread():    for i in range(1, 30):        print(f'{i} of 30 iterations...')        time.sleep(random.random())  # do some work...    print(f'{i} iterations completed before exiting.')
th = threading.Thread(target=bg_thread)th.start()th.join()
  • 使用下面命令来运行程序,在下面的程序运行中,当跑到第7次迭代时,按下Ctrl-C来中断程序,发现后台运行的程序并没有终止掉。而在第13次迭代时,再次按下Ctrl-C来中断程序,发现程序真的退出了。

$ python thread.py1 of 30 iterations...2 of 30 iterations...3 of 30 iterations...4 of 30 iterations...5 of 30 iterations...6 of 30 iterations...7 of 30 iterations...^CTraceback (most recent call last):  File "thread.py", line 14, in     th.join()  File "/Users/mgrinberg/.pyenv/versions/3.8.6/lib/python3.8/threading.py", line 1011, in join    self._wait_for_tstate_lock()  File "/Users/mgrinberg/.pyenv/versions/3.8.6/lib/python3.8/threading.py", line 1027, in _wait_for_tstate_lock    elif lock.acquire(block, timeout):KeyboardInterrupt8 of 30 iterations...9 of 30 iterations...10 of 30 iterations...11 of 30 iterations...12 of 30 iterations...13 of 30 iterations...^CException ignored in: Traceback (most recent call last):  File "/Users/mgrinberg/.pyenv/versions/3.8.6/lib/python3.8/threading.py", line 1388, in _shutdown    lock.acquire()KeyboardInterrupt:
  • 这很奇怪,不是吗?究其原因是,Python 有一些逻辑是会在进程退出前运行的,专门用来等待任何没有被配置为守护线程的后台线程结束,然后再把控制权真正交给操作系统。因此,该进程在其主线程运行时收到到了中断信号,并准备退出。首先,它需要等待后台线程运行结束。但是,这个线程对中断一无所知,这个线程只知道它需要在运行结束前完成 30次迭代。

  • Python 在退出过程中使用的等待机制有一个规定,当收到第二个中断信号时,就会中止。这就是为什么第二个 Ctrl-C 会立即结束进程。所以我们看到了,线程是不能被杀死!在下面的章节中,将向展示 Python 中的两个方式,来使线程及时结束。


2. 使用守护进程

Daemon Threads

  • 在上面提到过,在Python退出之前,它会等待任何非守护线程的线程。而守护线程就是,一个不会阻止Python解释器退出的线程。

  • 如何使一个线程成为一个守护线程?所有的线程对象都有一个daemon属性,可以在启动线程之前将这个属性设置为True,然后该线程就会被视为一个守护线程。下面是上面的示例应用程序,修改后守护线程版本:

import randomimport threadingimport time
def bg_thread():    for i in range(1, 30):        print(f'{i} of 30 iterations...')        time.sleep(random.random())  # do some work...    print(f'{i} iterations completed before exiting.')
th = threading.Thread(target=bg_thread)th.daemon = Trueth.start()th.join()
  • 再次运行它,并尝试中断它,发现第一个执行Ctrl-C后进程立即就退出了。

~ $ python x.py1 of 30 iterations...2 of 30 iterations...3 of 30 iterations...4 of 30 iterations...5 of 30 iterations...6 of 30 iterations...^CTraceback (most recent call last):  File "thread.py", line 15, in     th.join()  File "/Users/mgrinberg/.pyenv/versions/3.8.6/lib/python3.8/threading.py", line 1011, in join    self._wait_for_tstate_lock()  File "/Users/mgrinberg/.pyenv/versions/3.8.6/lib/python3.8/threading.py", line 1027, in _wait_for_tstate_lock    elif lock.acquire(block, timeout):KeyboardInterrupt
  • 那么这个线程会发生什么呢?线程继续运行,就像什么都没发生一样,直到Python进程终止并返回到操作系统。这时,线程就不存在了。你可能认为这实际上是一种杀死线程的方法,但要考虑到以这种方式杀死线程,你必须同时杀死进程。


3. 使用事件对象

Python Events

  • 使用守护线程,是一种避免在多线程程序中处理意外中断的简单方法,但这是一种只在进程退出的特殊情况下才有效的技巧。不幸的是,有些时候,一个应用程序可能想结束一个线程而不必杀死自己。另外,有些线程可能需要在退出前执行清理工作,而守护线程则不允许这样操作。

  • 那么,还有什么其他选择呢?既然不可能强制线程结束,那么唯一的选择就是给它添加逻辑,让它在被要求退出时自愿退出。有多种方法都可以解决上述问题,但我特别喜欢的一种方法,就是使用一个Event对象。

Event类是由Python标准库的线程模块提供,你可以通过实例化类来创建一个事件对象,就像下面这个样子:

exit_event = threading.Event()
  • Event对象可以处于两种状态之一:setnot set。当我们实例化创建之后,默认事件并没有被设置。

    • 若要将事件状态更改为set,则可以调用set()方法;

    • 要查明是否设置了事件,使用is_set()方法,设置了则返回True;

    • 还可以使用wait()方法等待事件,等待操作阻塞直到设置事件(可以设置超时)

  • 其核心思路,就是在线程需要退出的时候设置事件。然后,线程需要经常地检查事件的状态(通常是在循环中),并在发现事件已经设置时处理自己的终止。对于上面显示的示例,一个好的解决方案是添加一个捕获Ctrl-C中断的信号处理程序,而不是突然退出,只需设置事件并让线程优雅地结束。

import randomimport signalimport threadingimport time
exit_event = threading.Event()
def bg_thread():    for i in range(1, 30):        print(f'{i} of 30 iterations...')        time.sleep(random.random())  # do some work...        if exit_event.is_set():            break    print(f'{i} iterations completed before exiting.')
def signal_handler(signum, frame):    exit_event.set()
signal.signal(signal.SIGINT, signal_handler)th = threading.Thread(target=bg_thread)th.start()th.join()
  • 如果你尝试中断这个版本的应用程序,一切看起来都会更好:

$ python thread.py1 of 30 iterations...2 of 30 iterations...3 of 30 iterations...4 of 30 iterations...5 of 30 iterations...6 of 30 iterations...7 of 30 iterations...^C7 iterations completed before exiting.
  • 需要注意的是,中断是如何被优雅地处理的,以及线程能够运行在循环之后出现的代码。如果当线程需要在退出之前,关闭文件句柄或数据库连接时,这种方式就非常有用了。其能够在线程退出之前,运行清理代码有时是必要的,以避免资源泄漏。我在上面提到过,event对象也是可以等待的:

for i in range(1, 30):    print(f'{i} of 30 iterations...')    time.sleep(random.random())
    if exit_event.is_set():        break
  • 在每个迭代中,都有一个对time.sleep()的调用,这将阻塞线程。如果在线程sleep时设置了退出事件,那么它就不能检查事件的状态,因此在线程能够退出之前会有一个小的延迟。在这种情况下,如果有sleep,使用wait()方法将sleepevent对象的检查结合起来会更有效:

   for i in range(1, 30):        print(f'{i} of 30 iterations...')        if exit_event.wait(timeout=random.random()):            break

  • 这个解决方案有效地为提供了一个可中断的sleep,因为在线程停留在wait()调用的中间时设置了事件,那么等待将立即返回。


4. 总结陈述说明

Conclusion

  • 你知道Python中的event对象吗?它们是比较简单的同步原语之一,不仅可以用作退出信号,而且在线程需要等待某些外部条件发生的许多其他情况下也可以使用。

原文链接:https://www.escapelife.site/posts/558f583c.html

责任编辑:haq
声明:本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人,不代表电子发烧友网立场。文章及其配图仅供工程师学习之用,如有内容侵权或者其他违规问题,请联系本站处理。 举报投诉
  • python
    +关注

    关注

    56

    文章

    4795

    浏览量

    84658
  • 线程
    +关注

    关注

    0

    文章

    504

    浏览量

    19679

原文标题:如何杀死一个Python线程

文章出处:【微信号:magedu-Linux,微信公众号:马哥Linux运维】欢迎添加关注!文章转载请注明出处。

收藏 人收藏

    评论

    相关推荐

    Python中多线程和多进程的区别

    Python作为一种高级编程语言,提供了多种并发编程的方式,其中多线程与多进程是最常见的种方式之一。本文中,我们将探讨Python中多
    的头像 发表于 10-23 11:48 399次阅读
    <b class='flag-5'>Python</b>中多<b class='flag-5'>线程</b>和多进程的区别

    ad如何设置两个元器件的距离

    Altium Designer(简称AD)中设置两个元器件之间的距离,主要是通过设置元器件间的安全间距(Clearance)规则来实现的。这个规则定义了元器件之间、元器件与走线之间以及其他设计元素
    的头像 发表于 09-02 15:31 6876次阅读

    功放机AB两个声道输出怎么接

    功放机AB两个声道输出的接线方式,主要取决于您想要实现的音频效果以及音箱的配置。以下将详细介绍几种常见的接线方式,以及它们各自的特点和适用场景。 一、基础接线方式 大多数情况下,功放机的AB两个
    的头像 发表于 08-23 10:40 2689次阅读

    触发器的两个稳定状态分别是什么

    触发器作为数字电路中的基本逻辑单元,具有两个稳定状态,这两个状态通常用于表示二进制数码中的0和1。
    的头像 发表于 08-12 11:01 1113次阅读

    双稳态电路的两个稳定状态是什么

    双稳态电路是一种具有两个稳定状态的电子电路,广泛应用于数字电路、通信系统、存储器等领域。 双稳态电路的基本概念 双稳态电路是一种具有两个稳定状态的电路,即在没有外部输入信号的情况下,电路可以保持
    的头像 发表于 08-11 15:00 1371次阅读

    双稳态触发器的两个基本性质是什么

    双稳态触发器(Bistable Trigger)是一种具有两个稳定状态的逻辑电路,广泛应用于数字电路设计中。它具有两个基本性质:记忆性和切换性。 一、双稳态触发器的基本概念 1.1 双稳态触发器
    的头像 发表于 08-11 10:08 678次阅读

    两个PLC之间如何交互信号

    工业自动化系统中,PLC(Programmable Logic Controller,可编程逻辑控制器)是核心的控制设备。许多复杂的应用场景中,需要两个或多个PLC之间进行信号交互,以实现更高
    的头像 发表于 06-14 16:57 4332次阅读

    鸿蒙开发:【线程模型】

    管理其他线程的ArkTS引擎实例,例如使用TaskPool(任务池)创建任务或取消任务、启动和终止Worker线程
    的头像 发表于 06-13 16:38 403次阅读
    鸿蒙开发:【<b class='flag-5'>线程</b>模型】

    两个铜片可以形成原电池吗

    两个铜片本身不能形成原电池,因为原电池的工作原理依赖于两个不同电位的电极材料之间的氧化还原反应。
    的头像 发表于 05-21 16:23 948次阅读

    为什么交流电桥中至少需要两个可调参数?

    交流电桥的测量中,至少需要两个可调参数的原因与电桥的工作原理、测量的准确性以及校准过程有关。
    的头像 发表于 05-15 17:49 1851次阅读

    原电池中的两个电极能是相同的吗?

    原电池的设计和运作中,两个电极是否可以相同,这取决于电池的类型和所需的电化学反应。
    的头像 发表于 04-26 17:32 2295次阅读

    python中5种线程锁盘点

    线程安全是多线程或多进程编程中的一概念,拥有共享数据的多条线程并行执行的程序中,线程安全的代
    发表于 03-07 11:08 1587次阅读
    <b class='flag-5'>python</b>中5种<b class='flag-5'>线程</b>锁盘点

    arcgis中如何关联两个属性表

    ArcGIS中,关联两个属性表是一重要的操作,可以通过此操作将两个表中的数据关联起来,以便进行分析和查询。下面是详细介绍如何在ArcGIS中实现属性表的关联。 首先,我们需要明确
    的头像 发表于 02-25 11:01 4211次阅读

    求助,关于FX3的两个使用问题求解

    如题,咨询FX3的两个使用问题: 1,F1F模式下,烧写成功后,WIN10无法识别设备,切换到0F1,烧写成功后,WIN10同样无法识别设备,所以现在我的板子只能使用USB引导了,烧写到RAM可以
    发表于 02-22 07:16

    两个电位器地控制一变频器,如何接线?

    是一种可调节电阻器,可以通过改变电阻值来控制电流或电压。变频器是一种能够调整电机转速的设备,让电机不同的频率下工作。 3. 确定电位器的安装位置。在这个场景中,我们需要两个电位器来控制一变频器,所以需要将
    的头像 发表于 02-05 10:13 5250次阅读