jobqueue

Documentation

Index

• type HiveType
• type Job
• type SimplePool
  • func NewSimplePool(numWorkers int) *SimplePool
  • func (p *SimplePool) AddJob(job Job)
  • func (p *SimplePool) Run()
  • func (p *SimplePool) Stop()
• type SimpleWorker
  • func (w SimpleWorker) Start()
  • func (w SimpleWorker) Stop()
• type Worker
  • func (w Worker) Start()
  • func (w Worker) Stop()
• type WorkerDispatcher
  • func NewWorkerDispatcher() *WorkerDispatcher
  • func (w WorkerDispatcher) Dispatch(hiveType HiveType, jobQueue chan Job, numWorkers int)
  • func (w WorkerDispatcher) GetJobQueue(hiveType HiveType) chan Job
  • func (w WorkerDispatcher) NewWorker(workerPool chan chan Job) Worker
• type WorkerHive

Types

type HiveType

type HiveType string

type Job

type Job interface {
	PerformWork()
}

type SimplePool

type SimplePool struct {
	NumWorkers int
	// contains filtered or unexported fields
}

func NewSimplePool

func NewSimplePool(numWorkers int) *SimplePool

func (*SimplePool) AddJob

func (p *SimplePool) AddJob(job Job)

func (*SimplePool) Run

func (p *SimplePool) Run()

func (*SimplePool) Stop

func (p *SimplePool) Stop()

type SimpleWorker

type SimpleWorker struct {
	JobChannel  chan Job
	QuitChannel chan bool
}

func (SimpleWorker) Start

func (w SimpleWorker) Start()

func (SimpleWorker) Stop

func (w SimpleWorker) Stop()

type Worker

type Worker struct {
	WorkerPool  chan chan Job
	JobChannel  chan Job
	QuitChannel chan bool
}

func (Worker) Start

func (w Worker) Start()

func (Worker) Stop

func (w Worker) Stop()

type WorkerDispatcher

type WorkerDispatcher struct {
	WorkerHives map[HiveType]WorkerHive
}

func NewWorkerDispatcher

func NewWorkerDispatcher() *WorkerDispatcher

func (WorkerDispatcher) Dispatch

func (w WorkerDispatcher) Dispatch(hiveType HiveType, jobQueue chan Job, numWorkers int)

func (WorkerDispatcher) GetJobQueue

func (w WorkerDispatcher) GetJobQueue(hiveType HiveType) chan Job

func (WorkerDispatcher) NewWorker

func (w WorkerDispatcher) NewWorker(workerPool chan chan Job) Worker

type WorkerHive

type WorkerHive struct {
	Workers    []*Worker
	WorkerPool chan chan Job
	JobQueue   chan Job
}