task

Documentation

Overview

Package task provides a pool of goroutines to perform tasks.

Index

• type Task
  • func New(maxGoroutines int) *Task
  • func (t *Task) Do(w Worker)
  • func (t *Task) Shutdown()
• 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.

func (*Task) Do

func (t *Task) Do(w Worker)

Do submits work to the pool.

func (*Task) Shutdown

func (t *Task) Shutdown()

Shutdown waits for all the goroutines to shutdown.

type Worker

type Worker interface {
	Work()
}

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