Release v2.1.5

What's Changed

• Fixed write to closed channel in dispatcher by @korotin in #87

New Contributors

• @korotin made their first contribution in #87

Full Changelog: v2.1.4...v2.1.5

Release v2.1.4

What's Changed

• fix(dispatcher): ensure workers exit reliably when worker count is low by @alitto in #86

Full Changelog: v2.1.3...v2.1.4

Release v2.1.3

What's Changed

• fix(taskgroup): failed group tasks not counted by @alitto in #85

Full Changelog: v2.1.2...v2.1.3

Release v2.1.2

What's Changed

• fix(pool): fix race condition with small pool sizes by @alitto in #83

Full Changelog: v2.1.1...v2.1.2

Release v2.1.1

What's Changed

• feat(taskgroup): wait for ongoing tasks complete when group is stopped or context is cancelled by @alitto in #82

Full Changelog: v2.1.0...v2.1.1

Release v2.1.0

What's Changed

• feat(taskgroup): improve task group functionality by @alitto in #81
  • Added a new method to the pool to create a task group associated with a context (pool.NewGroupContext(ctx))
  • Added new methods to task groups:
    • group.Done(): returns a channel that is closed when all tasks in the group finish or the first error is returned.
    • group.Stop(): stops the task group. Queued tasks will be discarded but running tasks will complete their execution.
  • Added a new example showcasing the new pool.NewGroupContext(ctx) method.

Full Changelog: v2.0.4...v2.1.0

Release v2.0.4

What's Changed

• fix(group): do not panic when submitting zero tasks by @alitto in #79

Full Changelog: v2.0.3...v2.0.4

Release v2.0.3

What's Changed

• fix(taskgroups): do not start remaining tasks after context cancellation by @alitto in #77

Full Changelog: v2.0.2...v2.0.3

Release v2.0.2

Changes

• Expose Stopped() bool method in pools to indicate whether the pool has been stopped or its associated context has been cancelled.

Fixes

• Ensure ErrPoolStopped error is always returned when attempting to submit a task to a pool that has been stopped or its associated context cancelled.

Release v2.0.1

Fixes

• Avoid launching workers that exit immediately without running any tasks.
• Prevent task group Wait() from returning eagerly when tasks are executed before submitting the last one of the group.