golang不可重入函數實現

一個不可重入的函數就是一個在任何時間點只能執行一次的函數，不管它被呼叫了多少次，以及有多少goroutines。

某個服務是對某些條件進行輪詢，每秒監視一些狀態。我們希望每個狀態都可以獨立檢查，而不需要阻塞。

實作可能是這樣的：                                   選擇在自己的goroutine中運行每個狀態檢查，以便CheckAnotherStatus() 不會等待CheckSomeStatus() 完成。 每項檢查通常要花費很短的時間，而且比一秒鐘要少得多。但是，如果 CheckAnotherStatus() 本身需要超過一秒的時間來運行，會發生什麼事呢？可能會有一個意外的網路或磁碟延遲影響檢查的執行時間。

在同一時間執行兩次的函數是否有意義？如果沒有，我們希望它是不可重入的。

阻塞，不可重入函數

防止函數多次執行的簡單方法是使用sync.Mutex。

假設我們只關心從上面的循環呼叫這個函數，我們可以從函數外面實作鎖定：

func main() {
    tick := time.Tick(time.Second)     
    go func() {         
        for range tick {             
            go CheckSomeStatus()             
            go CheckAnotherStatus()         
        }     
    }() 
}

上面的程式碼保證了CheckAnotherStatus()不是由循環的多次迭代執行的。在以前執行 CheckAnotherStatus() 的時候，循環的任何後續迭代都會被互斥鎖阻塞。

阻塞解決方案具有以下屬性：

它確保了許多「CheckAnotherStatus()」的呼叫作為循環迭代的次數。 假設一個執行「CheckAnotherStatus()」的停頓，隨後的迭代會導致請求呼叫相同函數的請求。

屈服，不可重入函數

在我們的狀態檢查故事中，對隨後的10個電話堆積起來可能沒有意義。一個停滯不前的 CheckAnotherStatus() 執行完成了，所有10個呼叫突然執行，順序，並且可能在接下來的一秒內完成，在同一秒內完成10個相同的檢查。

另一個解決方法是屈服。一個有收益的解決方案是：

如果已經執行了「CheckAnotherStatus()」的中止執行。 將最多執行一次「CheckAnotherStatus()」的執行。

與循環迭代的次數相比，實際上可能運行的「CheckAnotherStatus()」的呼叫更少。

以上是golang不可重入函數實現的詳細內容。更多資訊請關注PHP中文網其他相關文章！