sched

Documentation

Overview

Copyright 2022 Changkun Ou <changkun.de>. All rights reserved. Use of this source code is governed by a GPLv3 license that can be found in the LICENSE file. https://hub.fastgit.xyz/polyred/polyred/blob/main/internal/sched/sched.go

Index

• type Option
  • func Randomizer(f func(min, max int) int) Option
  • func Workers(limit int) Option
• type Pool
  • func New(opts ...Option) *Pool
  • func (p *Pool) Add(numTasks int) int
  • func (p *Pool) Release()
  • func (p *Pool) Run(f ...func())
  • func (p *Pool) RunWithArgs(f func(args any), args any)
  • func (p *Pool) Running() uint64
  • func (p *Pool) Wait()

Types

type Option

type Option func(w *Pool)

Option is a scheduler option.

func Randomizer

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

func Workers

func Workers(limit int) Option

type Pool

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

Pool is a worker pool.

func New

func New(opts ...Option) *Pool

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

func (*Pool) Add

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

func (*Pool) Release

func (p *Pool) Release()

func (*Pool) Run

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

Run runs f in the current pool.

func (*Pool) RunWithArgs

func (p *Pool) RunWithArgs(f func(args any), args any)

func (*Pool) Running

func (p *Pool) Running() uint64

func (*Pool) Wait

func (p *Pool) Wait()