事件

• 其實就是開兩條線程,一條進行數據傳輸
• 另外一條,查看網絡是否安全,如果不行就會clear(),也就是給數據傳輸的那條線程一個信號,
• 主要原理就是wait()方法,只有當事件為True的時候才可以繼續運行,不然就會被wait()方法阻塞住,默認是False , is_set()方法是查看事件狀態的

# 模擬拿數據斷網了的操作from threading import Thread, Event import random import timee = Event()def foo():while 1:e.wait(3) # 阻塞,如果時間狀態為False則會阻塞,反之,可以通過time.sleep(0.6)if e.is_set() == True: # is_set 查看事件狀態為False還是Trueprint("拿到數據啦")else:print("斷網了")breakdef foo1():for i in range(5):time.sleep(1)state = iif state != 3:e.set() # 如果不為3,就把他設置成True,就可以取數據else:e.clear() # 如果為3,就設置成Falsedef foo2():time.sleep(4)e.set()t = Thread(target=foo) t1 = Thread(target=foo2) t.start() t1.start()

條件

• 總的來說條件就是一個更加復雜的鎖

# 條件其實就是更加復雜的鎖from threading import Thread,Conditioncond = Condition()def foo():cond.acquire() # 必須包裹住 wait() 方法cond.wait()print("進來一個")cond.release() # 必須包裹住 wait() 方法for i in range(10): # 設置10個線程,通過完就沒有了t = Thread(target=foo)t.start()while 1:num = input("請輸入放行的子進程個數:") # 相當于給線程設置了個告訴加油站的收費處cond.acquire() # 必須包裹住 notify() 方法cond.notify(int(num))cond.release() # 必須包裹住 notify() 方法

轉載于:https://www.cnblogs.com/xiongchao0823/p/11552405.html

《新程序員》：云原生和全面數字化實踐50位技術專家共同創作，文字、視頻、音頻交互閱讀

總結

以上是生活随笔為你收集整理的事件,条件的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。