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) 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.
Source Files
Click to show internal directories.
Click to hide internal directories.