limit

package

v0.0.1 Latest Latest Go to latest Published: Sep 20, 2026 License: MIT Imports: 1 Imported by: 0

Details

Package limit provides a channel-based semaphore for bounding concurrency.

This section is empty.

View Source

var ErrLimitReturn = errors.New("limit: discarding token, pool is full, returned multiple times")

ErrLimitReturn indicates more tokens were returned than borrowed.

This section is empty.

type Limit struct {
	// contains filtered or unexported fields
}

Limit controls the number of concurrent borrows.

func NewLimit(n int) Limit

NewLimit creates a Limit that can borrow n elements concurrently.

func (l Limit) Borrow()

Borrow borrows an element in blocking mode.

func (l Limit) Return() error

Return returns a borrowed element, erroring when returning more than borrowed.

func (l Limit) TryBorrow() bool

TryBorrow borrows an element without blocking.