在并行 goroutine 中使用速率限制器会导致竞争条件吗？

Question

作为对我的代码的极大简化，我有一个 goroutine 可以并行运行数千次，每个 goroutine 都在等待通过以下速率限制器运行golang.org/x/time/rate：func main() {  limiter := rate.NewLimiter(rate.Every(time.Second/100), 1) // 100 RPS  for _ := range jobs {    go run(&limiter)  }}func run(limiter *rate.Limiter) {  limiter.Wait()  // do stuff...}这个想法是run()尽可能频繁地执行，但限制为恰好 100 次调用/秒，以符合第三方 API 的 100 RPS 速率限制。limiter.Wait()当允许执行继续时，这会导致竞争条件吗？因为我仍然受到第三方的速率限制。

Answer 1

不，它没有。

limiter.Wait()是并发安全的，您可以在 Limiter 实现的源文件中看到这一点。

您可以在任何并发场景中自由使用 Limiter。