fix: fix pool busyness semantic with task queueing enabled

[poolifier.git] / src / pools / worker-node.ts

diff --git a/src/pools/worker-node.ts b/src/pools/worker-node.ts
index fcc091378565a4b78c7f9085619c9017169474d3..3b69d3854e07015aa0019ee84f164b8569ffe9aa 100644 (file)
--- a/src/pools/worker-node.ts
+++ b/src/pools/worker-node.ts
@@ -77,6 +77,8 @@ implements IWorkerNode<Worker, Data> {
   /** @inheritdoc */
   public closeChannel (): void {
     if (this.info.messageChannel != null) {
+      this.info.messageChannel?.port1.unref()
+      this.info.messageChannel?.port2.unref()
       this.info.messageChannel?.port1.close()
       this.info.messageChannel?.port2.close()
       delete this.info.messageChannel