worker

Documentation

Index

• type Dispatcher
  • func NewDispatcher(maxJobs, maxWorkers int, callbackC chan func()) *Dispatcher
  • func (d *Dispatcher) CallbackC() <-chan func()
  • func (d *Dispatcher) Exec(execFunc func() []byte, callbackFunc func([]byte))
  • func (d *Dispatcher) Run()

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(maxJobs, maxWorkers int, callbackC chan func()) *Dispatcher

func (*Dispatcher) CallbackC

func (d *Dispatcher) CallbackC() <-chan func()

func (*Dispatcher) Exec

func (d *Dispatcher) Exec(execFunc func() []byte, callbackFunc func([]byte))

func (*Dispatcher) Run

func (d *Dispatcher) Run()