worker

Documentation

Index

• type Pool
  • func NewPool(tasks []*Task, concurrency int) *Pool
  • func (p *Pool) Run()
• type Task
  • func NewTask(f func() error) *Task
  • func (t *Task) Run(wg *sync.WaitGroup)

Types

type Pool

type Pool struct {
	Tasks []*Task
	// contains filtered or unexported fields
}

Pool is the base model for tasks work group

func NewPool

func NewPool(tasks []*Task, concurrency int) *Pool

NewPool creates a worker pool given tasks and concurrency

func (*Pool) Run

func (p *Pool) Run()

Run runs all work within the pool and blocks until it's finished.

type Task

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

Task is the generic task model

func NewTask

func NewTask(f func() error) *Task

NewTask initializes a new task based on a given work function.

func (*Task) Run

func (t *Task) Run(wg *sync.WaitGroup)

Run runs a task and marks wait group as done