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中怎么实现一个不可重入函数的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注编程网行业资讯频道，感谢各位的阅读！