Piment Noir Git Repositories - poolifier.git/commit

feat!: add abortable task support (#1625)

* refactor: make worker a first class event emitter

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* docs: fix API documentation

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* docs: move changelog entry at the beginning

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* build(ci): silence linter errors

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* build: fix linter errors

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* build: silence linter error

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* feat: add delete op to priority queue

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* test: add priority queue delete() test

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* docs: add missing @param to workerNode.deleteTask()

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* docs: add code comment

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* refactor: silencer linter

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* fix: fix queues delete() implementation

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* fix: fix delete() in fixed queue

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* Update src/priority-queue.ts

* Update src/priority-queue.ts

* Update src/priority-queue.ts

* test: improve priority queue delete() coverage

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* build(ci): silence linting errors

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* refactor: code reformatting

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* refactor: code reformatting

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* refactor: code formatting

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* chore: fix merge issues

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* docs(api): formatting

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* chore: merge eslint-plugin-perfectionist reformatting

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* [autofix.ci] apply automated fixes

* chore: fix mismerge

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* chore: fix CHANGELOG.md mismerge

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* chore: silence linter

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* fix: ensure abort signal is defined before usage

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* refactor: code formatting

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* [autofix.ci] apply automated fixes

* [autofix.ci] apply automated fixes (attempt 2/3)

* refactor: make mapExecute() properly handle one abort signal per task
data

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* refactor: propagate abort signal error when possible

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* test: improve queue delete() coverage

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* test: add abort error UT

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* test: tests for tasks abortion

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* refactor: fix taskId type definition

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* refactor: cleanup AbortError properties

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* docs(README.md): refinement

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* fix: ensure task abortion play nice with task stealing

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
* fix: cascaded tasks abortion is legit

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
---------

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
Co-authored-by: Jérôme Benoit <jerome.benoit@sap.com>
Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>

author	Jérôme Benoit <jerome.benoit@piment-noir.org>
	Tue, 1 Jul 2025 13:24:02 +0000 (15:24 +0200)
committer	GitHub <noreply@github.com>
	Tue, 1 Jul 2025 13:24:02 +0000 (15:24 +0200)
commit	f4289ecb624ab84f01cf82e9177befaab2b50e28
tree	0de8151fde252a9a07bad72fa7acb2a95edcad70	tree \| snapshot (zip tar.gz tar.bz2)
parent	7e15dc8f7d97ac536328f0974eb6c75c2f048420	commit \| diff

.vscode/settings.json		diff \| blob \| blame \| history
README.md		diff \| blob \| blame \| history
docs/api.md		diff \| blob \| blame \| history
examples/typescript/http-server-pool/fastify-hybrid/@types/fastify/index.d.ts		diff \| blob \| blame \| history
examples/typescript/http-server-pool/fastify-hybrid/src/fastify-poolifier.ts		diff \| blob \| blame \| history
examples/typescript/http-server-pool/fastify-worker_threads/@types/fastify/index.d.ts		diff \| blob \| blame \| history
examples/typescript/http-server-pool/fastify-worker_threads/src/fastify-poolifier.ts		diff \| blob \| blame \| history
src/pools/abstract-pool.ts		diff \| blob \| blame \| history
src/pools/pool.ts		diff \| blob \| blame \| history
src/pools/utils.ts		diff \| blob \| blame \| history
src/pools/worker-node.ts		diff \| blob \| blame \| history
src/pools/worker.ts		diff \| blob \| blame \| history
src/queues/abstract-fixed-queue.ts		diff \| blob \| blame \| history
src/queues/priority-queue.ts		diff \| blob \| blame \| history
src/queues/queue-types.ts		diff \| blob \| blame \| history
src/utility-types.ts		diff \| blob \| blame \| history
src/worker/abort-error.ts	[new file with mode: 0644]	blob
src/worker/abstract-worker.ts		diff \| blob \| blame \| history
src/worker/cluster-worker.ts		diff \| blob \| blame \| history
src/worker/thread-worker.ts		diff \| blob \| blame \| history
src/worker/worker-types.ts	[new file with mode: 0644]	blob
tests/pools/abstract-pool.test.mjs		diff \| blob \| blame \| history
tests/pools/cluster/fixed.test.mjs		diff \| blob \| blame \| history
tests/pools/thread/fixed.test.mjs		diff \| blob \| blame \| history
tests/pools/utils.test.mjs		diff \| blob \| blame \| history
tests/pools/worker-node.test.mjs		diff \| blob \| blame \| history
tests/queues/fixed-priority-queue.test.mjs		diff \| blob \| blame \| history
tests/queues/fixed-queue.test.mjs		diff \| blob \| blame \| history
tests/queues/priority-queue.test.mjs		diff \| blob \| blame \| history
tests/worker/abort-error.test.mjs	[new file with mode: 0644]	blob
tests/worker/cluster-worker.test.mjs		diff \| blob \| blame \| history
tests/worker/thread-worker.test.mjs		diff \| blob \| blame \| history