scheduler

Documentation

Index

• type Options
  • func DefaultOptions() *Options
• type Scheduler
  • func NewScheduler(maxWorkers int, opts *Options) Scheduler

Types

type Options

type Options struct {
	// Threshold option represents the threshold at which batch task is enabled.
	Threshold int
	// IdleTime option represents the max idle time of the worker.
	IdleTime time.Duration
	// Interval option represents the check interval of the worker.
	Interval time.Duration
}

Options represents options

func DefaultOptions

func DefaultOptions() *Options

DefaultOptions returns default options.

type Scheduler

type Scheduler interface {
	// Schedule schedules the task to an idle worker.
	Schedule(task func())
	// NumWorkers returns the number of workers.
	NumWorkers() int
	// Close closes the task scheduler.
	Close()
}

Scheduler represents a task scheduler.

func NewScheduler

func NewScheduler(maxWorkers int, opts *Options) Scheduler

NewScheduler returns a new task scheduler.