semaphore

package

v0.11.10 Latest Latest Go to latest Published: Oct 20, 2026 License: MIT Imports: 5 Imported by: 2

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(size int64) (*Semaphore, error)

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

func (s *Semaphore) InitialSize() int64

Nominal size of the semaphore

func (s *Semaphore) Release(n int64)

func (s *Semaphore) Resize(ctx context.Context, newSize int64) error

func (s *Semaphore) Size() int64

Current size of the semaphore

func (s *Semaphore) Vary(ctx context.Context, x int64) error

Vary capacity by x - it's internally enqueued as a normal Acquire/Release operation as other Get/Put but tokens are held internally