worker

Documentation

Index

• type WorkerPool
  • func NewWorkerPool(maxConcurrentGoroutines, maxBufferGoroutines int) *WorkerPool
  • func (p *WorkerPool) Do(task func()) bool
  • func (p *WorkerPool) Wait()

Types

type WorkerPool

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

func NewWorkerPool

func NewWorkerPool(maxConcurrentGoroutines, maxBufferGoroutines int) *WorkerPool

func (*WorkerPool) Do

func (p *WorkerPool) Do(task func()) bool

Do add the task to worker pool and return whether it is added to the execution zone or buffer zone

func (*WorkerPool) Wait

func (p *WorkerPool) Wait()

Wait for all tasks before closing the channel