自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

除了 time.sleep,你還有一個暫停代碼的方法

開發(fā) 后端
現(xiàn)在大家想一想,有沒有什么辦法,在不使用time.sleep的情況下,讓程序暫停5秒?

我們知道,在 Python 里面可以使用time.sleep來讓代碼暫停一段時間,例如:

[[349670]]

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

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

現(xiàn)在大家想一想,有沒有什么辦法,在不使用time.sleep的情況下,讓程序暫停5秒?

你可能會說,用requests訪問一個延遲5秒的網(wǎng)址、或者用遞歸版算法計算斐波那契數(shù)列第36位……這些奇技淫巧。

不過今天我說的,是另外一個東西,threading模塊里面的Event。

我們來看看它的用法:

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

這樣一來,程序首先打印出...部分代碼...,然后等待5秒鐘,再打印出...剩下的代碼...。

功能看起來跟time.sleep沒什么區(qū)別,那為什么我要特別提到它呢?因為在多線程里面,它比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 是否有數(shù)據(jù)') 
  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() 

我來解釋一下這段代碼的意思。在主線程里面,我調(diào)用trigger_async_task()觸發(fā)了一個異步任務(wù)。這個任務(wù)多久完成我并不清楚。但是這個任務(wù)完成以后,它會往 Redis 里面發(fā)送一條消息,只要 Redis 有這個消息了,我就知道它完成了。所以我要創(chuàng)建一個 checker 子線程,每60秒去 Redis里面檢查任務(wù)是否完成。如果沒有完成,就暫停60秒,然后再檢查。

但某些情況下,我不需要等待了,例如用戶主動取消了任務(wù)。這個時候,我就想提前結(jié)束這個 checker 子線程。

但是我們知道,線程是不能從外面主動殺死的,只能讓它自己退出。所以當(dāng)我執(zhí)行event.set()后,子線程里面self.event.is_set()就會返回 False,于是這個循環(huán)就不會繼續(xù)執(zhí)行了。

可是,如果某一輪循環(huán)剛剛開始,我在主線程里面調(diào)用了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 是否有數(shù)據(jù)') 
  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)剛剛開始阻塞,只要我在主線程中執(zhí)行了event.set(),子線程里面的阻塞立刻就會結(jié)束。于是子線程立刻就會結(jié)束。不需要再白白等待60秒。

并且,event.wait()這個函數(shù)在底層是使用 C 語言實現(xiàn)的,不受 GIL 鎖的干擾。

 

責(zé)任編輯:趙寧寧 來源: 未聞Code
相關(guān)推薦

2020-12-22 06:04:13

Python定時代碼

2023-07-06 14:08:54

ChatGPTLLM大型語言模型

2011-06-22 15:09:34

Qt 線程 sleep

2019-11-08 09:24:35

KotlinJavaView

2021-08-23 11:35:37

代碼開發(fā)開源

2022-10-31 07:09:15

拷貝代碼項目

2020-06-17 07:56:19

前端存儲數(shù)據(jù)

2016-10-26 08:57:13

HadoopScrapy大數(shù)據(jù)

2022-07-27 15:30:24

媒體查詢css

2017-01-15 14:18:35

大數(shù)據(jù)HadoopScrapy

2021-08-30 08:40:02

網(wǎng)頁404HTTP

2016-11-22 19:37:54

Linux恢復(fù)文件

2017-12-07 15:05:50

全球互聯(lián)網(wǎng)創(chuàng)新峰會

2020-05-06 08:35:13

開源圖標(biāo)庫

2014-10-27 15:21:40

程序員代碼

2020-07-07 07:55:53

web app數(shù)據(jù)科學(xué)機(jī)器學(xué)習(xí)

2020-07-29 22:46:59

容器KubernetesPaaS

2021-09-27 10:03:55

裝飾器代碼

2022-12-02 08:48:16

CSS置灰網(wǎng)站

2009-06-06 19:15:39

imagebuffer
點贊
收藏

51CTO技術(shù)棧公眾號