一個(gè)不可重入的函數(shù)就是一個(gè)在任何時(shí)間點(diǎn)只能執(zhí)行一次的函數(shù)，不管它被調(diào)用了多少次，以及有多少goroutines。

創(chuàng)新互聯(lián)2013年開(kāi)創(chuàng)至今，是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司，擁有項(xiàng)目成都做網(wǎng)站、成都網(wǎng)站設(shè)計(jì)網(wǎng)站策劃，項(xiàng)目實(shí)施與項(xiàng)目整合能力。我們以讓每一個(gè)夢(mèng)想脫穎而出為使命，1280元哈密做網(wǎng)站,已為上家服務(wù),為哈密各地企業(yè)和個(gè)人服務(wù),聯(lián)系電話:028-86922220

某個(gè)服務(wù)是對(duì)某些條件進(jìn)行輪詢，每秒監(jiān)視一些狀態(tài)。我們希望每個(gè)狀態(tài)都可以獨(dú)立地檢查，而不需要阻塞。

實(shí)現(xiàn)可能是這樣的：

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

我們選擇在自己的goroutine中運(yùn)行每個(gè)狀態(tài)檢查，以便 CheckAnotherStatus() 不會(huì)等待 CheckSomeStatus() 完成。

每一項(xiàng)檢查通常都要花費(fèi)很短的時(shí)間，而且比一秒要少得多。但是，如果 CheckAnotherStatus() 本身需要超過(guò)一秒的時(shí)間運(yùn)行，會(huì)發(fā)生什么呢？可能會(huì)有一個(gè)意外的網(wǎng)絡(luò)或磁盤(pán)延遲影響檢查的執(zhí)行時(shí)間。

在同一時(shí)間執(zhí)行兩次的函數(shù)是否有意義？如果沒(méi)有，我們希望它是不可重入的。

阻塞，不可重入函數(shù)

防止函數(shù)多次運(yùn)行的簡(jiǎn)單方法是使用sync.Mutex。

假設(shè)我們只關(guān)心從上面的循環(huán)調(diào)用這個(gè)函數(shù)，我們可以從函數(shù)外面實(shí)現(xiàn)鎖：

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() 不是由循環(huán)的多次迭代執(zhí)行的。在以前執(zhí)行 CheckAnotherStatus() 的時(shí)候，循環(huán)的任何后續(xù)迭代都會(huì)被互斥鎖阻塞。

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

它確保了許多“CheckAnotherStatus()”的調(diào)用作為循環(huán)迭代的次數(shù)。

假設(shè)一個(gè)執(zhí)行“CheckAnotherStatus()”的停頓，隨后的迭代會(huì)導(dǎo)致請(qǐng)求調(diào)用相同函數(shù)的請(qǐng)求。

屈服，不可重入函數(shù)

在我們的狀態(tài)檢查故事中，對(duì)隨后的10個(gè)電話堆積起來(lái)可能沒(méi)有意義。一個(gè)停滯不前的 CheckAnotherStatus() 執(zhí)行完成了，所有10個(gè)調(diào)用突然執(zhí)行，順序，并且可能在接下來(lái)的一秒內(nèi)完成，在同一秒內(nèi)完成10個(gè)相同的檢查。

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

如果已經(jīng)執(zhí)行了“CheckAnotherStatus()”的中止執(zhí)行。

將最多運(yùn)行一次“CheckAnotherStatus()”的執(zhí)行。

與循環(huán)迭代的次數(shù)相比，實(shí)際上可能運(yùn)行的“CheckAnotherStatus()”的調(diào)用更少。

以上就是golang不可重入函數(shù)實(shí)現(xiàn)的詳細(xì)內(nèi)容，更多請(qǐng)關(guān)注創(chuàng)新互聯(lián)其它相關(guān)文章！

當(dāng)前題目：golang實(shí)現(xiàn)不可重入函數(shù)的方法
文章源于：http://aaarwkj.com/article22/gghccc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供微信公眾號(hào)、虛擬主機(jī)、網(wǎng)站設(shè)計(jì)、用戶體驗(yàn)、網(wǎng)頁(yè)設(shè)計(jì)公司、移動(dòng)網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)