pool

Documentation

Index

• func RunWithWorkers[T any](workerCount int, fn []func() JobResult[T]) <-chan JobResult[T]
• type Job
• type JobResult

Functions

func RunWithWorkers

func RunWithWorkers[T any](workerCount int, fn []func() JobResult[T]) <-chan JobResult[T]

Types

type Job

type Job[T any] func() JobResult[T]

type JobResult

type JobResult[T any] struct {
	Output T
	Err    error
}