sched

package

v0.6.1 Latest Latest Go to latest Published: Jun 10, 2022 License: MIT, GPL-3.0 Imports: 2 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 Queues(limit int) Option

Queues is buffer capacity of the tasks channel.

func Workers(limit int) Option

Workers is number of workers that can execute tasks concurrently.

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()