workerpool

Documentation

Index

• type WorkerFunc
• type WorkerPool
  • func New(size int) *WorkerPool
  • func (wp *WorkerPool) PublishJobData(jobData interface{})
  • func (wp *WorkerPool) Run(workerFunc WorkerFunc)

Types

type WorkerFunc

type WorkerFunc func(workerID int, jobData interface{})

type WorkerPool

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

func New

func New(size int) *WorkerPool

func (*WorkerPool) PublishJobData

func (wp *WorkerPool) PublishJobData(jobData interface{})

func (*WorkerPool) Run

func (wp *WorkerPool) Run(workerFunc WorkerFunc)