Because too much of the CPU consumed was golang.org/x/time/rate.Limiter.Wait()
calling time.Now()
.
This package uses ticks-per-second rather than time.Duration
, and is suitable for high-tickrate applications.
It allows you to change the rate by simply atomically changing an int32
. It has no practical limitation on the upper rate.
If you need a slower rate than once per second, you're better off using time.Ticker
.
One of the more common non-trivial usages of rate limiting is restricting some underlying operation(s)
being utilized by more complex worker goroutines. This package supports those with Ticker.Worker()
.
Assume we have a channel taskCh
where we read tasks to process, and then
want spawn worker goroutines that handle them. We want to spawn enough of them
to stay as close to the max rate as possible without starting too many of them.
for task := range taskCh {
// make sure to not alias variables you use in the lambda
// in case you use Go versions prior to 1.22.
task := task
if !ticker.Worker(func() { workerFn(ticker, task) }) {
// if ticker.Worker() fails to start the worker, it means the Ticker is closed.
break
}
}