Skip to content

Conversation

@nadmax
Copy link
Owner

@nadmax nadmax commented Jan 14, 2026

  • Modified Dequeue method to skip cancelled tasks in a loop
  • Updated TaskHandler signature to accept context.Context
  • Added cancellation monitoring in processTask method with 1s polling
  • Replaced blocking sleep with context-aware select in handlers
  • Tasks can now be cancelled during execution and workers immediately process next task

- Modified Dequeue method to skip cancelled tasks in a loop
- Updated TaskHandler signature to accept context.Context
- Added cancellation monitoring in processTask method with 1s polling
- Replaced blocking sleep with context-aware select in handlers
- Tasks can now be cancelled during execution and workers immediately process next task
@nadmax nadmax self-assigned this Jan 14, 2026
@nadmax nadmax added bug Something isn't working worker Something related to the worker tests Add or edit tests labels Jan 14, 2026
@nadmax nadmax merged commit 9cc53e0 into master Jan 14, 2026
11 checks passed
@nadmax nadmax deleted the queue branch January 14, 2026 09:25
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

bug Something isn't working tests Add or edit tests worker Something related to the worker

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants