semaphore

package

v2.0.0+incompatible Latest Latest Go to latest Published: Jan 29, 2020 License: Apache-2.0 Imports: 1 Imported by: 0

Details

Package semaphore provides an implementation of a counting semaphore.

This section is empty.

This section is empty.

This section is empty.

type Semaphore chan struct{}

Semaphore is a buffered channel based implementation of a counting semaphore.

func New(permits int) Semaphore

New creates a Semaphore with the specified number of permits.

func (s Semaphore) Acquire(ctx context.Context) error

Acquire acquires a permit. This call will block until a permit is available or the provided context is completed.

If the provided context is completed, the method will return the cancellation error.

func (s Semaphore) Release()

Release releases a permit.