workqueuekit

Documentation

Index

• type WorkQueue
  • func New(workerCount int, maxQueueSize int) *WorkQueue
  • func (w *WorkQueue) Done()
  • func (w *WorkQueue) QueueWork(work func())

Types

type WorkQueue

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

func New

func New(workerCount int, maxQueueSize int) *WorkQueue

func (*WorkQueue) Done

func (w *WorkQueue) Done()

func (*WorkQueue) QueueWork

func (w *WorkQueue) QueueWork(work func())