workers

Documentation

Index

• type Workers
  • func New(n int) (*Workers, error)
  • func (jt *Workers) Give()
  • func (jt *Workers) Take()
  • func (jt *Workers) Wait()

Types

type Workers

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

Workers provides a bounded semaphore with the ability to wait until all concurrent jobs finish.

func New

func New(n int) (*Workers, error)

New creates a Workers object which allows up to n jobs to proceed concurrently. n must be > 0.

func (*Workers) Give

func (jt *Workers) Give()

Give is how a job (goroutine) can give back its turn once done.

func (*Workers) Take

func (jt *Workers) Take()

Take is how a job (goroutine) can Take its turn.

func (*Workers) Wait

func (jt *Workers) Wait()

Wait waits for all ongoing concurrent jobs to complete