golang实现不可重入函数的方法-创新互联

一个不可重入的函数就是一个在任何时间点只能执行一次的函数,不管它被调用了多少次,以及有多少goroutines。

创新互联坚信:善待客户,将会成为终身客户。我们能坚持多年,是因为我们一直可值得信赖。我们从不忽悠初访客户,我们用心做好本职工作,不忘初心,方得始终。十年网站建设经验创新互联是成都老牌网站营销服务商,为您提供网站设计、网站建设、网站设计、H5响应式网站、网站制作、成都品牌网站建设微信小程序服务,给众多知名企业提供过好品质的建站服务。

某个服务是对某些条件进行轮询,每秒监视一些状态。我们希望每个状态都可以独立地检查,而不需要阻塞。

实现可能是这样的:

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不可重入函数实现的详细内容,更多请关注创新互联成都网站设计公司其它相关文章!

另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


分享名称:golang实现不可重入函数的方法-创新互联
URL链接:http://myzitong.com/article/djgipj.html