internal

Documentation

Index

• type Semaphore
  • func NewSemaphore(n int) Semaphore
  • func (s Semaphore) Acquire()
  • func (s Semaphore) Release()

Types

type Semaphore

type Semaphore chan struct{}

Semaphore is a thin wrapper around a channel for using it as a semaphore.

func NewSemaphore

func NewSemaphore(n int) Semaphore

NewSemaphore creates a semaphore that allows up to a given limit of simultaneous acquisitions.

func (Semaphore) Acquire

func (s Semaphore) Acquire()

Acquire is used to acquire an available slot. Blocks until available.

func (Semaphore) Release

func (s Semaphore) Release()

Release is used to return a slot. Acquire must be called as a pre-condition.