Golang中怎么實現一個不可重入函數

Golang中怎么實現一個不可重入函數，相信很多沒有經驗的人對此束手無策，為此本文總結了問題出現的原因和解決方法，通過這篇文章希望你能解決這個問題。

場景用例

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

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

我們選擇在自己的goroutine中運行每個狀態檢查，以便 CheckAnotherStatus() 不會等待 CheckSomeStatus() 完成。

每一項檢查通常都要花費很短的時間，而且比一秒要少得多。但是，如果 CheckAnotherStatus() 本身需要超過一秒的時間運行，會發生什么呢？可能會有一個意外的網絡或磁盤延遲影響檢查的執行時間。

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

import (     "sync"     "time" )

funcmain() {
    tick := time.Tick(time.Second)     var mu sync.Mutex     go func() {         for range tick {             go CheckSomeStatus()             go func() {                 mu.Lock()                 defer mu.Unlock()
                CheckAnotherStatus()             }()         }     }() }

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

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

• 它確保了許多“CheckAnotherStatus()”的調用作為循環迭代的次數。

• 假設一個執行“CheckAnotherStatus()”的停頓，隨后的迭代會導致請求調用相同函數的請求。

import (
    "sync/atomic"     "time"
)

func main() {     tick := time.Tick(time.Second)
    var reentranceFlag int64     go func() {
        for range tick {
            go CheckSomeStatus()             go func() {
                if atomic.CompareAndSwapInt64(&reentranceFlag, 0, 1) {                     defer atomic.StoreInt64(&reentranceFlag, 0)                 } else {
                     return                 }                 CheckAnotherStatus()             }()         }     }() }

看完上述內容，你們掌握Golang中怎么實現一個不可重入函數的方法了嗎？如果還想學到更多技能或想了解更多相關內容，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！