Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DispatchStatus ¶
type Dispatcher ¶
type Dispatcher struct {
// contains filtered or unexported fields
}
func CreateNewDispatcher ¶
func CreateNewDispatcher() *Dispatcher
func (*Dispatcher) AddJob ¶
func (d *Dispatcher) AddJob(je JobExecutable, repeat bool, repeatCount int, repeatCounter int)
func (*Dispatcher) Finished ¶
func (d *Dispatcher) Finished() bool
func (*Dispatcher) Start ¶
func (d *Dispatcher) Start(numWorkers uint64)
type JobExecutable ¶
type JobExecutable func() error
type Worker ¶
type Worker struct { ID uint64 Quit chan bool Dispatcher *Dispatcher // contains filtered or unexported fields }
func CreateNewWorker ¶
func CreateNewWorker(d *Dispatcher, id uint64, workerQueue chan *Worker, jobQueue chan *Job, dStatus chan *DispatchStatus) *Worker
Click to show internal directories.
Click to hide internal directories.