workerpool

Documentation

Index

• type Dispatcher
  • func NewDispatcher(maxWaitingJobs int, maxWorkers int) *Dispatcher
  • func (d *Dispatcher) AddWorker(handler JobHandler)
  • func (d *Dispatcher) Dispatch()
  • func (d *Dispatcher) Queue(job Job)
  • func (d *Dispatcher) Run()
  • func (d *Dispatcher) Stop()
• type Job
• type JobHandler
• type Worker
  • func (w *Worker) Run()
  • func (w *Worker) Stop()

Types

type Dispatcher

type Dispatcher struct {
	WorkerPool chan chan Job
	WorkerList []*Worker
	JobQueue   chan Job
	// contains filtered or unexported fields
}

func NewDispatcher

func NewDispatcher(maxWaitingJobs int, maxWorkers int) *Dispatcher

func (*Dispatcher) AddWorker

func (d *Dispatcher) AddWorker(handler JobHandler)

func (*Dispatcher) Dispatch

func (d *Dispatcher) Dispatch()

func (*Dispatcher) Queue

func (d *Dispatcher) Queue(job Job)

func (*Dispatcher) Run

func (d *Dispatcher) Run()

func (*Dispatcher) Stop

func (d *Dispatcher) Stop()

type Job

type Job interface{}

type JobHandler

type JobHandler func(w *Worker, j Job)

type Worker

type Worker struct {
	Id         int
	WorkerPool chan chan Job
	JobChannel chan Job

	Args interface{}
	// contains filtered or unexported fields
}

func (*Worker) Run

func (w *Worker) Run()

func (*Worker) Stop

func (w *Worker) Stop()