Python Thread虛假喚醒概念與防范詳解

更新時間：2023年02月28日 09:59:34 作者：狂飆-高啟強-張頌文-王天龍

這篇文章主要介紹了Python Thread虛假喚醒概念與防范，虛假喚醒是一種現(xiàn)象，它只會出現(xiàn)在多線程環(huán)境中，指的是在多線程環(huán)境下，多個線程等待在同一個條件上，等到條件滿足時，所有等待的線程都被喚醒，但由于多個線程執(zhí)行的順序不同

什么是虛假喚醒

虛假喚醒是一種現(xiàn)象，它只會出現(xiàn)在多線程環(huán)境中，指的是在多線程環(huán)境下，多個線程等待在同一個條件上，等到條件滿足時，所有等待的線程都被喚醒，但由于多個線程執(zhí)行的順序不同，后面競爭到鎖的線程在獲得時間片時條件已經(jīng)不再滿足，線程應該繼續(xù)睡眠但是卻繼續(xù)往下運行的一種現(xiàn)象。

上面是比較書面化的定義，我們用人能聽懂的話來介紹一下虛假喚醒。

多線程環(huán)境的編程中，我們經(jīng)常遇到讓多個線程等待在一個條件上，等到這個條件成立的時候我們再去喚醒這些線程，讓它們接著往下執(zhí)行代碼的場景。假如某一時刻條件成立，所有的線程都被喚醒了，然后去競爭鎖，因為同一時刻只會有一個線程能拿到鎖，其他的線程都會阻塞到鎖上無法往下執(zhí)行，等到成功爭搶到鎖的線程消費完條件，釋放了鎖，后面的線程繼續(xù)運行，拿到鎖時這個條件很可能已經(jīng)不滿足了，這個時候線程應該繼續(xù)在這個條件上阻塞下去，而不應該繼續(xù)執(zhí)行，如果繼續(xù)執(zhí)行了，就說發(fā)生了虛假喚醒。

import threading
from threading import Condition
class Data:
    def __init__(self, cond, num):
        self.num = num
        self.cond = cond
    def add(self):
        self.cond: Condition = self.cond
        self.cond.acquire()
        if self.num > 0:
            self.cond.wait()
        self.num += 1
        print(threading.current_thread().getName(), self.num)
        self.cond.notifyAll()
        self.cond.release()
    def decr(self):
        self.cond: Condition = self.cond
        self.cond.acquire()
        if self.num == 0:
            self.cond.wait()
        self.num -= 1
        print(threading.current_thread().getName(), self.num)
        self.cond.notifyAll()
        self.cond.release()
if __name__ == '__main__':
    cond = Condition()
    num = 0
    data = Data(cond, 0)
    thread_add = threading.Thread(name="A", target=data.add)
    thread_decr = threading.Thread(name="B", target=data.decr)
    thread_add.start()
    thread_decr.start()

現(xiàn)在改用4個線程

import threading
from threading import Condition
class Data:
    def __init__(self, cond, num):
        self.num = num
        self.cond = cond
    def add(self):
        self.cond: Condition = self.cond
        self.cond.acquire()
        if self.num > 0:
            self.cond.wait()
        self.num += 1
        print(threading.current_thread().getName(), self.num)
        self.cond.notifyAll()
        self.cond.release()
    def decr(self):
        self.cond: Condition = self.cond
        self.cond.acquire()
        if self.num == 0:
            self.cond.wait()
        self.num -= 1
        print(threading.current_thread().getName(), self.num)
        self.cond.notifyAll()
        self.cond.release()
if __name__ == '__main__':
    cond = Condition()
    num = 0
    data = Data(cond, 0)
    thread_add = threading.Thread(name="A", target=data.add)
    thread_decr = threading.Thread(name="B", target=data.decr)
    thread_add2 = threading.Thread(name="C", target=data.add)
    thread_decr2 = threading.Thread(name="D", target=data.decr)
    thread_add.start()
    thread_decr.start()
    thread_add2.start()
    thread_decr2.start()

還沒有出現(xiàn)問題?。?！

使用20個線程同時跑

import threading
from threading import Condition
class Data:
    def __init__(self, cond, num):
        self.num = num
        self.cond = cond
    def add(self):
        self.cond: Condition = self.cond
        self.cond.acquire()
        if self.num > 0:
            self.cond.wait()
        self.num += 1
        print(threading.current_thread().getName(), self.num)
        self.cond.notifyAll()
        self.cond.release()
    def decr(self):
        self.cond: Condition = self.cond
        self.cond.acquire()
        if self.num == 0:
            self.cond.wait()
        self.num -= 1
        print(threading.current_thread().getName(), self.num)
        self.cond.notifyAll()
        self.cond.release()
if __name__ == '__main__':
    cond = Condition()
    num = 0
    data = Data(cond, 0)
    for i in range(10):
        thread_add = threading.Thread(name="A", target=data.add)
        thread_add.start()
    for i in range(10):
        thread_decr = threading.Thread(name="B", target=data.decr)
        thread_decr.start()

這時就出現(xiàn)了問題！?。?/p>

現(xiàn)在改用while進行判斷

防止虛假喚醒：

import threading
from threading import Condition
class Data:
    def __init__(self, cond, num):
        self.num = num
        self.cond = cond
    def add(self):
        self.cond: Condition = self.cond
        self.cond.acquire()
        # 這里采用了while進行判斷，防止虛假喚醒
        while self.num > 0:
            self.cond.wait()
        self.num += 1
        print(threading.current_thread().getName(), self.num)
        self.cond.notifyAll()
        self.cond.release()
    def decr(self):
        self.cond: Condition = self.cond
        self.cond.acquire()
        # 這里采用了while進行判斷，防止虛假喚醒
        while self.num == 0:
            self.cond.wait()
        self.num -= 1
        print(threading.current_thread().getName(), self.num)
        self.cond.notifyAll()
        self.cond.release()
if __name__ == '__main__':
    cond = Condition()
    num = 0
    data = Data(cond, 0)
    for i in range(10):
        thread_add = threading.Thread(name="A", target=data.add)
        thread_add.start()
    for i in range(10):
        thread_decr = threading.Thread(name="B", target=data.decr)
        thread_decr.start()