semaphore

Documentation

Overview

Package semaphore provides an implementation of a counting semaphore.

Index

• type Semaphore
  • func New(permits int) Semaphore
  • func (s Semaphore) Acquire(ctx context.Context) error
  • func (s Semaphore) Release()

Types

type Semaphore

type Semaphore chan struct{}

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

func New

func New(permits int) Semaphore

New creates a Semaphore with the specified number of permits.

func (Semaphore) Acquire

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 (Semaphore) Release

func (s Semaphore) Release()

Release releases a permit.