Len returns the number of elements in the buffer that haven't yet been read

Creates a new task group.

Creates a new task group with the specified context.

NewResultPool creates a new result pool with the given maximum concurrency and options. Result pools are generic pools that can be used to submit task

Creates a new subpool with the specified maximum concurrency and options.

** * Asserts that the function not panics. */

Read reads values from the buffer and returns the number of elements read

Stops the group and cancels all remaining tasks. Running tasks are not interrupted.

Stops the group and cancels all remaining tasks. Running tasks are not interrupted.

Submits a task to the group.

Submits a task to the pool and returns a future that can be used to wait for the task to complete and get the result. The task function must return a

Submits a task to the group that can return an error.

Test that submitting tasks while the pool is stopping doesn't lead to a data race. Author: https://github.com/korotin

verifies that the deprecated Result interface and ResultTask are compatible. by assigning ResultTask to Result, testing for compatibility

ensures that a function expecting Result[T] can accept a ResultTask[T] testing for usage pattern