jobtokens

Documentation

Index

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

Types

type JobTokens

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

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

func New

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

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

func (*JobTokens) Give

func (jt *JobTokens) Give()

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

func (*JobTokens) Take

func (jt *JobTokens) Take()

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

func (*JobTokens) Wait

func (jt *JobTokens) Wait()

Wait waits for all ongoing concurrent jobs to complete