map_pool

Documentation

Index

• type JobWithResult
• type Pool
  • func New[U any](workerCount int) *Pool[U]
  • func (p *Pool[U]) AddJob(job JobWithResult[U])
  • func (p *Pool[U]) Close()
  • func (p *Pool[U]) Results() <-chan U
  • func (p *Pool[U]) Start()

Types

type JobWithResult

type JobWithResult[U any] func() (U, error)

JobWithResult represents a job function that takes an input of type T and returns a result of type U and an error.

type Pool

type Pool[U any] struct {
	// contains filtered or unexported fields
}

func New

func New[U any](workerCount int) *Pool[U]

func (*Pool[U]) AddJob

func (p *Pool[U]) AddJob(job JobWithResult[U])

func (*Pool[U]) Close

func (p *Pool[U]) Close()

func (*Pool[U]) Results

func (p *Pool[U]) Results() <-chan U

func (*Pool[U]) Start

func (p *Pool[U]) Start()