python中断time.sleep一种更优雅的方式:event.wait

 更新时间:2023年11月10日 09:00:10   作者:Rnan-prince  
这篇文章主要介绍了python中断time.sleep一种更优雅的方式:event.wait,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

场景描述

实现一个功能,启动一个线程,只要线程不中断,就一直while true,间断10s累加某个数;

当线程线程信号时,while停止,线程退出。

1、方法一 time.sleep

import time
from threading import Thread
 
 
class AddTask(Thread):
 
    def __init__(self):
        super().__init__()
        self.sum_num = 0
        self._button = True
 
    def run(self):
        print('Begin to add ...')
        while self._button:
            print('Sleep start...')
            time.sleep(10)
            print('Sleep end...')
            self.sum_num += 10
        print(f"Finish add, sum:{self.sum_num}...")
 
    def stop(self):
        print('Stop task...')
        self._button = False
 
 
def do_main_task():
    print('Do main task...')
    time.sleep(15)
    print('Finish main task...')
    return True
 
 
if __name__ == '__main__':
    add_task = AddTask()
    add_task.start()
    main_task_end = do_main_task()
    if main_task_end:
        add_task.stop()
        time.sleep(1)
        print(f"sum: {add_task.sum_num}")

执行结果:

Begin to add ...Do main task...
Sleep start...
Sleep end...
Sleep start...
Finish main task...
Stop task...
sum: 10
Sleep end...
Finish add,sum: 20...

解释一下这段代码的意思。在主线程里面,我调用do_main_task()触发了一个任务。这个任务执行会久一些(这里设定15s)。但是这个任务完成以后,会有个返回值,告诉我完成了。另外创建一个 add_task 子线程,每10秒累加10。

但某些情况下,我不需要等待了,例如用户主动取消了任务。这个时候,我就想提前结束这个 add_task 子线程。

通过执行结果可以看出,当执行一次+10,等待10s后,又过了5秒,主线程do_main_task结束了,这时add_task线程还在累加的sleep(10)中没有退出。主线程执行结果已经是sum=10,再过5秒后add_task线程才结束。

但是,线程是不能从外面主动杀死的,只能让它自己退出。

2、方法二 event.wait

应用threading模块里面的Event

用法和sleep差不多:

import threading
 
event = threading.Event()
event.wait(5)

上述例子可以这样实现:

import time
from threading import Thread
from threading import Event
 
 
class AddTask(Thread):
 
    def __init__(self):
        super().__init__()
        self.sum_num = 0
        self.event = Event()
 
    def run(self):
        print('Begin to add ...')
        while not self.event.is_set():
            print('Sleep start...')
            self.event.wait(10)
            print('Sleep end...')
            self.sum_num += 10
        print(f"Finish add, sum:{self.sum_num}...")
 
    def stop(self):
        print('Stop task...')
        self.event.set()
 
 
def do_main_task():
    print('Do main task...')
    time.sleep(15)
    print('Finish main task...')
    return True
 
 
if __name__ == '__main__':
    add_task = AddTask()
    add_task.start()
    main_task_end = do_main_task()
    if main_task_end:
        add_task.stop()
        time.sleep(1)
        print(f"sum: {add_task.sum_num}")

执行结果:

Do main task...
Begin to add ...
Sleep start...
Sleep end...
Sleep start...
Finish main task...
Stop task...
Sleep end...
Finish add, sum:20...

sum: 20

当执行event.set()后,子线程里面self.event.is_set()就会返回 False,于是这个循环就不会继续执行了。

即使self.event.wait(10)刚刚开始阻塞,只要我在主线程中执行了event.set(),子线程里面的阻塞立刻就会结束。

于是子线程立刻就会结束。不需要再白白等待10秒。

并且,event.wait()这个函数在底层是使用 C 语言实现的,不受 GIL 锁的干扰。

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • 关于python的list相关知识(推荐)

    关于python的list相关知识(推荐)

    下面小编就为大家带来一篇关于python的list相关知识(推荐)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-08-08
  • python简单商城购物车实例代码

    python简单商城购物车实例代码

    这篇文章主要为大家详细介绍了python简单商城购物车的实例代码,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-03-03
  • Python爬虫实现百度翻译功能过程详解

    Python爬虫实现百度翻译功能过程详解

    这篇文章主要介绍了Python爬虫实现百度翻译功能过程详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-05-05
  • Python numpy二维数组如何删除指定行和列

    Python numpy二维数组如何删除指定行和列

    本文展示了如何对数组进行行列删除操作,包括删除单行、单列、多行和多列的方法,通过具体的运行结果展示,读者可以清晰地了解到如何在不同情况下进行数据处理,文章内容实用,适合需要进行数据处理的读者参考学习
    2024-09-09
  • 给Python初学者的一些编程技巧

    给Python初学者的一些编程技巧

    这篇文章主要介绍了给Python初学者的一些编程技巧,皆是基于基础的一些编程习惯建议,需要的朋友可以参考下
    2015-04-04
  • Python中代码执行失败原因分析与解决

    Python中代码执行失败原因分析与解决

    本文将深入探讨Python代码执行失败的原因、常见的错误类型、诊断方法以及解决方案,感兴趣的小伙伴可以跟随小编一起学习一下
    2024-10-10
  • python处理excel绘制雷达图

    python处理excel绘制雷达图

    这篇文章主要为大家介绍了python处理excel绘制雷达图的相关方法,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-10-10
  • 解决python pip安装第三方模块报错:error:legacy-install-failure

    解决python pip安装第三方模块报错:error:legacy-install-failure

    pip是python的第三方库管理器,可以根据所开发项目的需要,使用pip相关命令安装不同库,下面这篇文章主要给大家介绍了关于解决python pip安装第三方模块报错:error: legacy - install - failure的相关资料,需要的朋友可以参考下
    2023-04-04
  • python之PyMongo使用总结

    python之PyMongo使用总结

    本篇文章主要介绍了python之PyMongo使用总结,详细的介绍了PyMongo模块的使用,具有一定的参考价值,有兴趣的可以了解一下
    2017-05-05
  • Python基于locals返回作用域字典

    Python基于locals返回作用域字典

    这篇文章主要介绍了Python基于locals返回作用域字典,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-10-10

最新评论