workerpool

Documentation

Index

• Variables
• type Dispatcher
  • func NewDispatcher() *Dispatcher
  • func (d *Dispatcher) Run()
• type Job
• type Worker
  • func NewWorker(workerPool chan chan Job) Worker
  • func (w Worker) Start()
  • func (w Worker) Stop()

Variables

var JobQueue chan Job

Types

type Dispatcher

type Dispatcher struct {
	// A pool of worker channels.
	WorkerPool chan chan Job
}

func NewDispatcher

func NewDispatcher() *Dispatcher

func (*Dispatcher) Run

func (d *Dispatcher) Run()

type Job

type Job struct {
	Command *exec.Cmd
}

type Worker

type Worker struct {
	WorkerPool chan chan Job
	JobChannel chan Job
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(workerPool chan chan Job) Worker

func (Worker) Start

func (w Worker) Start()

func (Worker) Stop

func (w Worker) Stop()