Golang中怎么實(shí)現(xiàn)一個(gè)不可重入函數(shù)

Golang中怎么實(shí)現(xiàn)一個(gè)不可重入函數(shù)，相信很多沒(méi)有經(jīng)驗(yàn)的人對(duì)此束手無(wú)策，為此本文總結(jié)了問(wèn)題出現(xiàn)的原因和解決方法，通過(guò)這篇文章希望你能解決這個(gè)問(wèn)題。

場(chǎng)景用例

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

funcmain() {
    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)有，我們希望它是不可重入的。

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() 不是由循環(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)求。

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()             }()         }     }() }

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