scheduler

Documentation

Index

• type Dispatcher
  • func NewDispatcher(maxWorker int) *Dispatcher
  • func (d *Dispatcher) AddJob(job Job) bool
  • func (d *Dispatcher) Close()
  • func (d *Dispatcher) Run()
• type Job
• type Worker
  • func NewWorker(d *Dispatcher, ID int) *Worker
  • func (w *Worker) Start()
  • func (w *Worker) Stop()

Types

type Dispatcher

type Dispatcher struct {
	TaskChannel     chan Job      // Store all job
	DispatchControl chan bool     // Control add job go routine
	WorkerPool      chan chan Job // Store worker private job channel
	WorkerList      []*Worker     // Store worker instance
	MaxWorker       int           // Max worker number
	IsClosed        bool          // Dispatcher is closed ?
}

Dispatcher is used to dispatch job

func NewDispatcher

func NewDispatcher(maxWorker int) *Dispatcher

NewDispatcher is used to create dispatch

func (*Dispatcher) AddJob

func (d *Dispatcher) AddJob(job Job) bool

AddJob is used job to global job channel

func (*Dispatcher) Close

func (d *Dispatcher) Close()

Close dispatch

func (*Dispatcher) Run

func (d *Dispatcher) Run()

Run dispatcher

type Job

type Job func()

Job scheduler must implement method

type Worker

type Worker struct {
	Dispatcher *Dispatcher
	JobChannel chan Job
	Quit       chan bool
	ID         int
}

Worker struct

func NewWorker

func NewWorker(d *Dispatcher, ID int) *Worker

NewWorker is used to create a new worker

func (*Worker) Start

func (w *Worker) Start()

Start worker

func (*Worker) Stop

func (w *Worker) Stop()

Stop worker