Golang Go语言中关于 time/rate 中取消返回 token 的问题(bug?)

发布于 1周前 作者 caililin 来自 Go语言

官方包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

2 回复

确实好像是 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语言的官方文档或寻求社区的帮助。

回到顶部