pool

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 27, 2023 License: MIT Imports: 1 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewPool

func NewPool[I any, O any](workers int, jobFunc JobFn[I, O], options ...option[I, O]) async.Processor[I, O]

func WithSortingOutput added in v0.3.0

func WithSortingOutput[I any, O any]() option[I, O]

Types

type JobFn

type JobFn[I any, O any] func(I) (O, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL