worker

Documentation

Index

• type WorkQueue
  • func NewWorkQueue(maxQueueSize int) *WorkQueue
  • func (w *WorkQueue) AddJob(job jobType) bool
  • func (w *WorkQueue) NumJobs() int
  • func (w *WorkQueue) Shutdown()
  • func (w *WorkQueue) StartWorkers(num int)
  • func (w *WorkQueue) WaitForJobs()

Types

type WorkQueue

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

func NewWorkQueue

func NewWorkQueue(maxQueueSize int) *WorkQueue

func (*WorkQueue) AddJob

func (w *WorkQueue) AddJob(job jobType) bool

func (*WorkQueue) NumJobs

func (w *WorkQueue) NumJobs() int

func (*WorkQueue) Shutdown

func (w *WorkQueue) Shutdown()

func (*WorkQueue) StartWorkers

func (w *WorkQueue) StartWorkers(num int)

func (*WorkQueue) WaitForJobs

func (w *WorkQueue) WaitForJobs()