parahelpers

Documentation

Index

• type Group
  • func RunGroup[T any](ctx context.Context, cfg GroupConfig[T]) Group[T]
• type GroupConfig

Types

type Group

type Group[T any] interface {
	Enqueue(T) error
	Wait() error
}

Group is a group of workers that can be used to enqueue work and wait for them to finish.

func RunGroup

func RunGroup[T any](ctx context.Context, cfg GroupConfig[T]) Group[T]

RunGroup creates a new Group with the given configuration.

type GroupConfig

type GroupConfig[T any] struct {
	NumWorkers int
	Handle     func(context.Context, T) error
}

GroupConfig is the configuration for a new Group.