sync

Documentation

Index

• type WorkerPool
  • func NewWorkerPool(size int) WorkerPool

Types

type WorkerPool

type WorkerPool interface {

	// Schedule try to acquire pooled worker goroutine to execute the specified task,
	// this method would block if no worker goroutine is available
	Schedule(task func())

	// Schedule try to acquire pooled worker goroutine to execute the specified task first,
	// but would not block if no worker goroutine is available. A temp goroutine will be created for task execution.
	ScheduleAlways(task func())

	ScheduleAuto(task func())
}

WorkerPool provides a pool for goroutines

func NewWorkerPool

func NewWorkerPool(size int) WorkerPool

NewWorkerPool create a worker pool