task

Documentation

Index

• type Task
  • func New(maxGoroutines int) *Task
  • func (t *Task) Do(w Worker)
  • func (t *Task) Shutdown() error
• type Worker

Types

type Task

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

Task provides a pool of goroutines that can execute any Worker tasks that are submitted.

func New

func New(maxGoroutines int) *Task

New creates a new work pool. instanced with singleton pattern beacuse used centrally as worker pool based on CPU resources

func (*Task) Do

func (t *Task) Do(w Worker)

Do submits work to the pool.

func (*Task) Shutdown

func (t *Task) Shutdown() error

Shutdown waits for all the goroutines to shutdown.

type Worker

type Worker interface {
	Work() error
}

Worker must be implemented by types that want to use the run pool.