limiter

Documentation

Index

• type Limiter
  • func New(k uint) *Limiter
  • func (lim *Limiter) Active() int
  • func (lim *Limiter) Start() func()
  • func (lim *Limiter) Wait()

Types

type Limiter

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

Limits the number of goroutines and allows you to wait for the worker group to complete.

func New

func New(k uint) *Limiter

Returns new limiter which restrains the size of worker group with number less or equal k.

func (*Limiter) Active

func (lim *Limiter) Active() int

Returns a number of active workers.

func (*Limiter) Start

func (lim *Limiter) Start() func()

Adds a new worker to groups and returns "done" function, which must be run to decrement worker counter.

func (*Limiter) Wait

func (lim *Limiter) Wait()

Blocks until all workers complete their tasks.