文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

除了 time.sleep,你还有一个暂停代码的方法

2024-12-03 18:11

关注

[[349670]]

  1. import time 
  2.  
  3. print('...部分代码...') 
  4. time.sleep(5) 
  5. print('...剩下的代码...') 

程序首先打印出...部分代码...,然后等待5秒钟,再打印出...剩下的代码...。

现在大家想一想,有没有什么办法,在不使用time.sleep的情况下,让程序暂停5秒?

你可能会说,用requests访问一个延迟5秒的网址、或者用递归版算法计算斐波那契数列第36位……这些奇技淫巧。

不过今天我说的,是另外一个东西,threading模块里面的Event。

我们来看看它的用法:

  1. import threading 
  2.  
  3. event = threading.Event() 
  4. print('...部分代码...') 
  5. event.wait(5) 
  6. print('...剩下的代码...') 

这样一来,程序首先打印出...部分代码...,然后等待5秒钟,再打印出...剩下的代码...。

功能看起来跟time.sleep没什么区别,那为什么我要特别提到它呢?因为在多线程里面,它比time.sleep更有用。我们来看一个例子:

  1. import threading 
  2.  
  3. class Checker(threading.Thread): 
  4.     def __init__(self, event): 
  5.         super().__init__() 
  6.         self.event = event 
  7.  
  8.     def run(self): 
  9.         while not self.event.is_set(): 
  10.             print('检查 redis 是否有数据') 
  11.             time.sleep(60) 
  12.  
  13. trigger_async_task() 
  14. event = threading.Event() 
  15. checker = Checker(event) 
  16. checker.start() 
  17. if user_cancel_task(): 
  18.     event.set() 

我来解释一下这段代码的意思。在主线程里面,我调用trigger_async_task()触发了一个异步任务。这个任务多久完成我并不清楚。但是这个任务完成以后,它会往 Redis 里面发送一条消息,只要 Redis 有这个消息了,我就知道它完成了。所以我要创建一个 checker 子线程,每60秒去 Redis里面检查任务是否完成。如果没有完成,就暂停60秒,然后再检查。

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

但是我们知道,线程是不能从外面主动杀死的,只能让它自己退出。所以当我执行event.set()后,子线程里面self.event.is_set()就会返回 False,于是这个循环就不会继续执行了。

可是,如果某一轮循环刚刚开始,我在主线程里面调用了event.set()。此时,子线程还在time.sleep中,那么子线程需要等待60秒才会退出。

但如果我修改一下代码,使用self.event.wait(60):

  1. import threading 
  2.  
  3. class Checker(threading.Thread): 
  4.     def __init__(self, event): 
  5.         super().__init__() 
  6.         self.event = event 
  7.  
  8.     def run(self): 
  9.         while not self.event.is_set(): 
  10.             print('检查 redis 是否有数据') 
  11.             self.event.wait(60) 
  12.  
  13. trigger_task() 
  14. event = threading.Event() 
  15. checker = Checker(event) 
  16. checker.start() 
  17. if user_cancel_task(): 
  18.     event.set() 

那么,即便self.event.wait(60)刚刚开始阻塞,只要我在主线程中执行了event.set(),子线程里面的阻塞立刻就会结束。于是子线程立刻就会结束。不需要再白白等待60秒。

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

 

来源:未闻Code内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯