sched

package

v0.5.3 Latest Latest Go to latest Published: May 20, 2022 License: MIT, GPL-3.0 Imports: 3 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type Option func(w *Pool)

Option is a scheduler option.

func Randomizer(f func(min, max int) int) Option

func Workers(limit int) Option

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

Pool is a worker pool.

func New(opts ...Option) *Pool

New creates a new task scheduler and returns a pool of workers.

func (p *Pool) Add(numTasks int) int

func (p *Pool) IsRunning() bool

func (p *Pool) Release()

func (p *Pool) Run(f ...func())

Run runs f in the current pool.

func (p *Pool) RunWithArgs(f func(args interface{}), args interface{})

func (p *Pool) Running() uint64

func (p *Pool) Wait()

func (p *Pool) WaitAndRelease()