Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConcurrencyLimiter ¶
type ConcurrencyLimiter struct {
// contains filtered or unexported fields
}
ConcurrencyLimiter is a limiter that allows a maximum number of concurrent operations to be executed.
Safe for concurrent use.
func NewConcurrencyLimiter ¶
func NewConcurrencyLimiter(maxConcurrent uint32) (*ConcurrencyLimiter, error)
NewConcurrencyLimiter creates a new ConcurrencyLimiter with the given maximum number of concurrent operations.
func (*ConcurrencyLimiter) Acquire ¶
func (h *ConcurrencyLimiter) Acquire() bool
Acquire atomically increments the concurrency counter if it is below the configured limit. Returns true if the slot was acquired, false if the limit was reached. The caller MUST call [Release] exactly once after a successful Acquire.
func (*ConcurrencyLimiter) Allow ¶
func (h *ConcurrencyLimiter) Allow(fn func()) bool
Allow executes fn if the number of concurrent operations is below the configured limit. Returns true if fn was executed, false if the limit was reached and fn was not called. The concurrency counter is decremented when fn returns, including on panic.
func (*ConcurrencyLimiter) Release ¶
func (h *ConcurrencyLimiter) Release()
Release decrements the concurrency counter, freeing a slot previously obtained via [Acquire]. Must be called exactly once for every successful [Acquire] call. Panics if called without a matching [Acquire] (counter underflow).
Source Files