Pull requests

• fix(pool): avoid race conditions when a task is submitted while the pool is stopping by @alitto in #105
• feat(pool): add non-blocking submission methods and dropped tasks metric by @alitto in #107

Changes

• Ensure closed atomic bool is toggled and checked while holding the mutex to avoid race conditions.
• Ensure workersWaitGroup.Add() is always called while holding the mutex to avoid race conditions.
• Improve comments on submit methods to clarify the behavior when the pool is stopped.
• Refactor trySubmit method to make it simpler and more clear.
• Centralize worker launch in a new method called launchWorker.
• Replace subpoolSubmit with subpoolWorker method.
• Add methods to submit individual tasks in a non-blocking fashion (TrySubmit and TrySubmitErr). Requested in #103
• Expose new DroppedTasks metric that reflects the number of tasks that were not executed because the queue was full. Issue reported in #100
• SubmittedTasks metric now includes dropped tasks and it stops being updated once the pool is stopped.

Fixes

• Decrement workerCount counter when the pool context is cancelled.
• Resize() now supports setting maxConcurrency to 0 (no limit)

Full Changelog: v2.3.0...v2.3.1

What's Changed

• feat(pool): add support for dynamically adjusting max concurrency by @alitto in #102

Full Changelog: v2.2.0...v2.3.0

What's Changed

• feat(pool): add option to bound task queue (v2) by @alitto in #99
  • Add support to create bounded pools by specifying a queue size (WithQueueSize option).
  • Add support to choose how to deal with tasks submitted when the queue is full (WithNonBlocking option).
  • Ensure RunningWorkers() method in subpools reflect the actual number of workers running tasks belonging to the subpool.
  • Allow overriding pool options when creating a subpool via NewSupool.
  • Simplify pool submission logic and remove dispatcher goroutine.
  • Simplify subpool implementation.

Full Changelog: v2.1.6...v2.2.0

What's Changed

• Fix typos by @deining in #89
• GitHub actions: fix warning by @deining in #90
• Automated version check for GitHub workflow actions by @deining in #93
• fix(panics): wrap panic errors correctly and include stack trace in #96 (thanks @deregtd 🙌)

New Contributors

• @deining made their first contribution in #89

Full Changelog: v2.1.5...v2.1.6

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

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

What's Changed

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

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

What's Changed

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

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

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

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