worker

Documentation

Index

• type WorkerPool
  • func (this *WorkerPool) ActiveWorksCount() int
  • func (this *WorkerPool) AddWork(task func()) (err error)
  • func (this *WorkerPool) Quit()
  • func (this *WorkerPool) QuitWait()
  • func (this *WorkerPool) Start(maxWorkers int)
• type WorkerPoolUnlimited
  • func (this *WorkerPoolUnlimited) AddWork(task func()) (err error)
  • func (this *WorkerPoolUnlimited) Quit()
  • func (this *WorkerPoolUnlimited) QuitWait()

Types

type WorkerPool

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

func (*WorkerPool) ActiveWorksCount

func (this *WorkerPool) ActiveWorksCount() int

func (*WorkerPool) AddWork

func (this *WorkerPool) AddWork(task func()) (err error)

func (*WorkerPool) Quit

func (this *WorkerPool) Quit()

func (*WorkerPool) QuitWait

func (this *WorkerPool) QuitWait()

func (*WorkerPool) Start

func (this *WorkerPool) Start(maxWorkers int)

type WorkerPoolUnlimited

type WorkerPoolUnlimited struct {
	// max idle time before closing a worker
	MaxIdle time.Duration
	// contains filtered or unexported fields
}

func (*WorkerPoolUnlimited) AddWork

func (this *WorkerPoolUnlimited) AddWork(task func()) (err error)

func (*WorkerPoolUnlimited) Quit

func (this *WorkerPoolUnlimited) Quit()

func (*WorkerPoolUnlimited) QuitWait

func (this *WorkerPoolUnlimited) QuitWait()