scheduler

Documentation

Index

• type Job
• type Scheduler
  • func Elastic() Scheduler
  • func Immediate() Scheduler
  • func NewElastic(size int) Scheduler
  • func NewParallel(n int) Scheduler
  • func NewSingle(cap int) Scheduler
  • func Parallel() Scheduler
  • func Single() Scheduler
• type Worker

Types

type Job

type Job func()

type Scheduler

type Scheduler interface {
	io.Closer
	Worker() Worker
}

func Elastic

func Elastic() Scheduler

func Immediate

func Immediate() Scheduler

func NewElastic

func NewElastic(size int) Scheduler

func NewParallel

func NewParallel(n int) Scheduler

func NewSingle

func NewSingle(cap int) Scheduler

func Parallel

func Parallel() Scheduler

func Single

func Single() Scheduler

type Worker

type Worker interface {
	Do(Job)
}