内容简介：一个不可重入的函数就是一个在任何时间点只能执行一次的函数，不管它被调用了多少次，以及有多少goroutines。本篇文章说明了阻塞不可重入函数，并在golang中产生不可重入的函数实现。某个服务是对某些条件进行轮询，每秒监视一些状态。我们希望每个状态都可以独立地检查，而不需要阻塞。实现可能是这样的：
女主宣言
一个不可重入的函数就是一个在任何时间点只能执行一次的函数，不管它被调用了多少次，以及有多少goroutines。
PS：丰富的一线技术、多元化的表现形式，尽在“ HULK一线技术杂谈 ”，点关注哦！
一个不可重入的函数就是一个在任何时间点只能执行一次的函数，不管它被调用了多少次，以及有多少goroutines。
本篇文章说明了阻塞不可重入函数，并在golang中产生不可重入的函数实现。
场景用例
某个服务是对某些条件进行轮询，每秒监视一些状态。我们希望每个状态都可以独立地检查，而不需要阻塞。实现可能是这样的：
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()”的调用更少。
解决方案是通过以下方式实现的：
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()
}()
}
}()
}
atomic.compareandswapint64(&reentranceFlag, 0, 1) 只有在 reentranceFlag==0 时才会返回true，并将原子性地设置为1。在这种情况下，允许进入，并且可以执行该函数。reentranceFlag保持在1，直到 CheckAnotherStatus() 完成，此时它被重置。当 CompareAndSwapInt64(...) 返回false时，这意味着reentranceFlag!=0，这意味着该函数已经由另一个goroutine执行。代码产生并静默地退出函数。
总结
我们选择在问题的函数之外实现不可重入的代码；我们可以在函数本身中实现它。另外，对于 int64 而言，int32当然也足够用。 以上就是本篇的内容，大家有什么疑问可以在文章下面留言沟通。
HULK一线技术杂谈
由360云平台团队打造的技术分享公众号，内容涉及 云计算 、 数据库 、 大数据 、 监控 、 泛前端 、 自动化测试 等众多技术领域，通过夯实的技术积累和丰富的一线实战经验，为你带来最有料的技术分享
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持 码农网
猜你喜欢:
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
深入理解Nginx（第2版）
陶辉 / 机械工业出版社 / 2016-2 / 99.00元
本书致力于说明开发Nginx模块的必备知识，第1版发行以后，深受广大读者的喜爱．然而由于Ng,nx功能繁多且性能强大，以致必须了解的基本技能也很庞杂，而第1版成书匆忙，缺失了几个进阶的技巧描述，因此第2版在此基础上进行了完善。 书中首先通过介绍官方Nginx的基本用法和配置规则，帮助读者了解一般Nginx模块的用法，然后重点介绍了女口何开发HTTP模块(含HTTP过滤模块)来得到定制化的Ng......一起来看看 《深入理解Nginx（第2版）》 这本书的介绍吧!
