joque

Documentation

Index

• func Setup(maxQueueSize int, maxWorkers int) chan Job
• type Dispatcher
  • func NewDispatcher(jobQueue chan Job, maxWorkers int) *Dispatcher
• type Job
• type Worker
  • func NewWorker(id int, workerPool chan chan Job) Worker

Functions

func Setup

func Setup(maxQueueSize int, maxWorkers int) chan Job

Setup

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(jobQueue chan Job, maxWorkers int) *Dispatcher

NewDispatcher creates, and returns a new Dispatcher object.

type Job

type Job func()

Job is a unit of work.

type Worker

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

func NewWorker

func NewWorker(id int, workerPool chan chan Job) Worker

NewWorker creates takes a numeric id and a channel w/ worker pool.