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

創新互聯2013年開創至今，是專業互聯網技術服務公司，擁有項目成都做網站、成都網站設計網站策劃，項目實施與項目整合能力。我們以讓每一個夢想脫穎而出為使命，1280元哈密做網站,已為上家服務,為哈密各地企業和個人服務,聯系電話:028-86922220

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

實現可能是這樣的：

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

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

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

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

阻塞，不可重入函數

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

假設我們只關心從上面的循環調用這個函數，我們可以從函數外面實現鎖：

import (     "sync"     "time" )
func main() {
    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()”的停頓，隨后的迭代會導致請求調用相同函數的請求。

屈服，不可重入函數

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

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

如果已經執行了“CheckAnotherStatus()”的中止執行。

將最多運行一次“CheckAnotherStatus()”的執行。

與循環迭代的次數相比，實際上可能運行的“CheckAnotherStatus()”的調用更少。

以上就是golang不可重入函數實現的詳細內容，更多請關注創新互聯其它相關文章！

當前題目：golang實現不可重入函數的方法
文章源于：http://vcdvsql.cn/article22/gghccc.html

成都網站建設公司_創新互聯，為您提供微信公眾號、虛擬主機、網站設計、用戶體驗、網頁設計公司、移動網站建設

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯