task

func Close ¶

func Close(v interface{}) func() error

Close returns a func() that closes v.

func OnSuccess ¶

func OnSuccess(f func() error, g func() error) func() error

OnSuccess executes g() after f() returns nil.

func ParallelForN ¶

func ParallelForN(n int, fn func(i int) error) error

ParallelForN runs fn(0..n-1) in parallel across runtime.GOMAXPROCS(0) worker goroutines. Indices are partitioned into contiguous chunks so the number of spawned goroutines stays bounded regardless of n.

fn must be safe to call concurrently from different goroutines (each call receives its own unique index). Output collected by writing to indexed slots in a pre-allocated slice is a common safe pattern.

Returns the first non-nil error reported by fn; other workers may still be finishing briefly afterwards.

func Run ¶

func Run(ctx context.Context, tasks ...func() error) error

Run executes a list of tasks in parallel, returns the first error encountered or nil if all tasks pass.