pool

Documentation

Overview

Package pool contains a generic worker pool

Index

• type Pool
  • func NewPool(ctx context.Context, ch chan t.PoolData) *Pool
  • func (p *Pool) Cancel()
  • func (p *Pool) Start(numWorkers int, callback PoolCallback)
  • func (p *Pool) Wait()
• type PoolCallback

Types

type Pool

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

Pool is a generic worker pool using t.PoolData as the datatype

func NewPool

func NewPool(ctx context.Context, ch chan t.PoolData) *Pool

NewPool creates a new Pool

func (*Pool) Cancel

func (p *Pool) Cancel()

Cancel cancels the jobs in the pool

func (*Pool) Start

func (p *Pool) Start(numWorkers int, callback PoolCallback)

Start starts numWorkers number of workers on the pool, each running callback

func (*Pool) Wait

func (p *Pool) Wait()

Wait waits for the pool jobs to complete

type PoolCallback

type PoolCallback func(t.PoolData)

PoolCallback is the data process callback