workerqueue

Documentation

Index

• type Interface
  • func NewWorkerQueue(size int) Interface
• type WorkerQueue
  • func (wq *WorkerQueue) Add(f *func())
  • func (wq *WorkerQueue) Stop()

Types

type Interface

type Interface interface {
	Add(*func())
	Stop()
}

Interface of a workerqueue.

func NewWorkerQueue

func NewWorkerQueue(size int) Interface

NewWorkerQueue creates new WorkerQueue with worker group of given size.

type WorkerQueue

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

WorkerQueue is worker group with a task queue.

func (*WorkerQueue) Add

func (wq *WorkerQueue) Add(f *func())

Add adds a new task to the queue.

func (*WorkerQueue) Stop

func (wq *WorkerQueue) Stop()

Stop stops the working group.