Skip to content

Commit

Permalink
Reword godoc in LimitedConcurrencySingleFlight
Browse files Browse the repository at this point in the history
  • Loading branch information
dimitarvdimitrov committed Sep 20, 2022
1 parent 769f9c1 commit 126e8a8
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions concurrency/limited_concurrency_singleflight.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,8 @@ import (
"github.com/grafana/dskit/multierror"
)

// LimitedConcurrencySingleFlight ensures that for any number of concurrent ForEachNotInFlight calls each with any number of tokens only up to maxConcurrent f
// invocations are executing concurrently. See the docs of ForEachNotInFlight for the uniqueness semantics of tokens.
// LimitedConcurrencySingleFlight ensures that across all concurrent calls to ForEachNotInFlight, only up to maxConcurrent
// tokens are running concurrently. See the docs of ForEachNotInFlight for the uniqueness semantics of tokens.
type LimitedConcurrencySingleFlight struct {
inflightTokensMx sync.Mutex
inflightTokens map[string]struct{}
Expand Down

0 comments on commit 126e8a8

Please sign in to comment.