semaphore

Documentation

Index

• type Semaphore
  • func NewSemaphore(maxConcurrentOps uint) *Semaphore
  • func (s *Semaphore) Acquire()
  • func (s *Semaphore) Count() int
  • func (s *Semaphore) Limit() int
  • func (s *Semaphore) Release()
  • func (s *Semaphore) Wait()

Types

type Semaphore

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

Semaphore is a semaphore implementation.

func NewSemaphore

func NewSemaphore(maxConcurrentOps uint) *Semaphore

NewSemaphore creates a new semaphore with the given limit.

func (*Semaphore) Acquire

func (s *Semaphore) Acquire()

Acquire acquires a semaphore.

func (*Semaphore) Count

func (s *Semaphore) Count() int

Count returns the number of acquired semaphores.

func (*Semaphore) Limit

func (s *Semaphore) Limit() int

Limit returns the limit of the semaphore.

func (*Semaphore) Release

func (s *Semaphore) Release()

Release releases a semaphore.

func (*Semaphore) Wait

func (s *Semaphore) Wait()

Wait waits for all acquired semaphores to be released.