worker

Documentation

Index

• type Pool
  • func NewPool(minRoutines int64) (Pool, error)
• type Task

Types

type Pool

type Pool interface {
	RunTask(task Task)
	Stop() error
}

Pool is the interface which must be implemented by our worker pool.

func NewPool

func NewPool(minRoutines int64) (Pool, error)

NewPool returns a new worker pool with the given number of goroutines. The returned pool can then be used to add task which are then processed by the worker pool.

type Task

type Task interface {
	Do()
}

Task is the interface which must be implemented by each task which should be added to the worker pool.