semaphore

Documentation

Index

• type Semaphore
  • func New(maxConcurrentNum int64) *Semaphore
  • func (s *Semaphore) Acquire() error
  • func (s *Semaphore) Release()
  • func (s *Semaphore) Wait() error

Types

type Semaphore

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

func New

func New(maxConcurrentNum int64) *Semaphore

New creates a new Semaphore instance

func (*Semaphore) Acquire

func (s *Semaphore) Acquire() error

Acquire acquires a semaphore, blocking until resources are available

func (*Semaphore) Release

func (s *Semaphore) Release()

Release releases a semaphore

func (*Semaphore) Wait

func (s *Semaphore) Wait() error

Wait acquires the MaxConcurrentNum semaphore, blocking until all resources are available