semaphore

Documentation

Index

• type Semaphore
  • func New(n int) *Semaphore
  • func (s *Semaphore) Len() int
  • func (s *Semaphore) Signal()
  • func (s *Semaphore) Wait()
  • func (s *Semaphore) Waiting() int

Types

type Semaphore

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

Semaphore used to control access to a common resource by multiple goroutines.

func New

func New(n int) *Semaphore

New returns a new counting semaphore of length `n`.

func (*Semaphore) Len

func (s *Semaphore) Len() int

Len returns the number of goroutines currently acquired the semaphore.

func (*Semaphore) Signal

func (s *Semaphore) Signal()

Signal the semaphore. A random waiting goroutine will be waken up.

func (*Semaphore) Wait

func (s *Semaphore) Wait()

Wait for the semaphore. Blocks until the resource is available.

func (*Semaphore) Waiting

func (s *Semaphore) Waiting() int

Waiting returs the number of waiting goroutines on the semaphore.