semaphore

package

v0.0.0-...-3e0e934 Latest Latest Go to latest Published: Jun 28, 2026 License: Apache-2.0, BSD-2-Clause Imports: 4 Imported by: 0

Details

Package semaphore provides a weighted semaphore implementation. ref: https://github.com/golang/go/issues/29721

This section is empty.

This section is empty.

This section is empty.

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

func NewLimiter(limit int64) *Limiter

func (l *Limiter) Acquire(ctx context.Context) error

func (l *Limiter) Current() int64

func (l *Limiter) Limit() int64

func (l *Limiter) Peak() int64

func (l *Limiter) Release()

func (l *Limiter) SetLimit(limit int64)

func (l *Limiter) TryAcquire() (success bool)

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

func NewWeighted(n int64) *Weighted

func (s *Weighted) Acquire(ctx context.Context, n int64) error

func (s *Weighted) GetCurrent() int64

func (s *Weighted) Release(n int64)

func (s *Weighted) Resize(n int64)

func (s *Weighted) Size() int64

func (s *Weighted) TryAcquire(n int64) (int64, bool)