Golang Go语言中关于 time/rate 中取消返回 token 的问题(bug?)
官方包golang.org/x/time
中 cancel 的部分,返回 token 的代码( CancelAt )
https://github.com/golang/time/blob/e5dcc9cfc0b9553953e355dde5bdf4ff9f82f742/rate/rate.go#L168
// calculate tokens to restore
// The duration between lim.lastEvent and r.timeToAct tells us how many tokens were reserved
// after r was obtained. These tokens should not be restored.
// 这行代码多减了一次最近申请的预支的 token ,用测试代码说明一下
restoreTokens := float64(r.tokens) - r.limit.tokensFromDuration(r.lim.lastEvent.Sub(r.timeToAct))
if restoreTokens <= 0 {
return
}
// advance time to now
now, _, tokens := r.lim.advance(now)
// calculate new number of tokens
tokens += restoreTokens
if burst := float64(r.lim.burst); tokens > burst {
tokens = burst
}
测试代码
t0 := time.Now()
l := NewLimiter(1, 10)
l.ReserveN(t0, 5) //桶里还剩 5 个 token
r := l.ReserveN(t0, 10) // 桶里还剩 -5 个 token
fmt.Printf("%+v\n", l)
l.ReserveN(t0, 2) // 桶里还有 -7 个
fmt.Printf("%+v\n", l)
//
r.CancelAt(t0) // -7 + (10 - 2) = 1
fmt.Printf("%+v\n", l)
l.ReserveN(t0, 8) // -7
fmt.Printf("%+v\n", l)
// 这样到了第七秒就只消费了 5+8+2=15 ,而取消之前应该是 5+10+2=17 ,取消之后 token 的总数变少了
Golang Go语言中关于 time/rate 中取消返回 token 的问题(bug?)
更多关于Golang Go语言中关于 time/rate 中取消返回 token 的问题(bug?)的实战系列教程也可以访问 https://www.itying.com/category-94-b0.html
确实好像是 bug
更多关于Golang Go语言中关于 time/rate 中取消返回 token 的问题(bug?)的实战系列教程也可以访问 https://www.itying.com/category-94-b0.html
在Go语言的time/rate
包中,关于取消返回token的问题,实际上并不是bug,而是设计上的特性。time/rate
包主要用于限制操作的速率,比如限制某个接口的访问频率。
在time/rate.Limiter
中,当你调用Allow()
方法时,如果当前时间允许,它会返回一个token并允许操作进行。然而,Allow()
方法并没有提供直接取消或回收token的机制。这是因为time/rate
的设计是基于时间窗口的速率限制,而不是基于token数量的限制。
如果你在某次调用Allow()
后决定不执行该操作,那么实际上你并不需要(也无法)取消或回收这个token。因为time/rate
的速率限制是基于时间的流逝自动调整的,不会因为某个token没有被使用而改变。
如果你担心未使用的token会影响速率限制的效果,那么可以放心,time/rate
的设计已经考虑到了这一点。它会根据时间的推移和配置的速率限制自动调整可用的token数量。
因此,如果你在使用time/rate
时遇到了看似与取消token相关的问题,实际上可能是误解了time/rate
的工作原理。建议重新审查你的使用场景和代码逻辑,确保你正确地理解了time/rate
的速率限制机制。如果仍有疑问,可以查阅Go语言的官方文档或寻求社区的帮助。