woker_pool

Documentation

Index

• type Dispatcher
  • func NewDispatcher(workers int) *Dispatcher
  • func (d *Dispatcher) Start()
  • func (d *Dispatcher) Stop()
• type Task
• type TaskCh
• type Worker
  • func NewWorker(ID int, workerCh chan TaskCh) *Worker
  • func (w *Worker) Done()
  • func (w *Worker) Start()

Types

type Dispatcher

type Dispatcher struct {
	// contains filtered or unexported fields
}

func NewDispatcher

func NewDispatcher(workers int) *Dispatcher

func (*Dispatcher) Start

func (d *Dispatcher) Start()

func (*Dispatcher) Stop

func (d *Dispatcher) Stop()

type Task

type Task interface {
	Run()
}

type TaskCh

type TaskCh chan Task

type Worker

type Worker struct {
	ID int
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(ID int, workerCh chan TaskCh) *Worker

func (*Worker) Done

func (w *Worker) Done()

func (*Worker) Start

func (w *Worker) Start()