zsync

Documentation

Index

• type MaxLimiter
  • func NewMaxLimiter(max int) *MaxLimiter
  • func (l *MaxLimiter) Lock()
  • func (l *MaxLimiter) Unlock()

Types

type MaxLimiter

type MaxLimiter struct {
	Active  int
	Pending int
	Max     int
	// contains filtered or unexported fields
}

func NewMaxLimiter

func NewMaxLimiter(max int) *MaxLimiter

Keep number of active locks below the Max count. Useful for limiting the number of goroutines running simultaneously

func (*MaxLimiter) Lock

func (l *MaxLimiter) Lock()

Lock will wait until Active < Max

func (*MaxLimiter) Unlock

func (l *MaxLimiter) Unlock()

Must call unlock when work is completed