parallel

Documentation

Index

• func Enqueue(ctx context.Context, fn func() error) <-chan error
• func GetMaxThreads() uint
• func SetMaxThreads(threads uint) error

Functions

func Enqueue

func Enqueue(ctx context.Context, fn func() error) <-chan error

Enqueue adds a single function to the parallel jobs queue. This function will be run when an unused thread is available. Returns a receive-only error channel that will return the error (if any) from the provided function fn when fn has finished executing. The channel will be closed after this.

func GetMaxThreads

func GetMaxThreads() uint

GetMaxThreads returns the current number of threads that will be used for parallel jobs.

func SetMaxThreads

func SetMaxThreads(threads uint) error

SetMaxThreads sets the number of threads that will be used for parallel jobs.