X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fworker-node.ts;h=5d28802c12769c1cbaf0cd519e22708918788016;hb=0d4e88b32dcc9af05423c40e049fb2693012b6d8;hp=64400d9eb1426be9ffe546b45855b606bfec05c0;hpb=95d1a734d57942c892202df7c0fcaf2fb5ab89ab;p=poolifier.git

diff --git a/src/pools/worker-node.ts b/src/pools/worker-node.ts
index 64400d9e..5d28802c 100644
--- a/src/pools/worker-node.ts
+++ b/src/pools/worker-node.ts
@@ -95,6 +95,12 @@ export class WorkerNode<Worker extends IWorker, Data = unknown>
     return this.tasksQueue.dequeue(bucket)
   }
 
+  /** @inheritdoc */
+  public dequeueLastBucketTask (): Task<Data> | undefined {
+    // Start from the last empty or partially filled bucket
+    return this.tasksQueue.dequeue(this.tasksQueue.buckets + 1)
+  }
+
   /** @inheritdoc */
   public clearTasksQueue (): void {
     this.tasksQueue.clear()