X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fworker-node.ts;h=5d28802c12769c1cbaf0cd519e22708918788016;hb=f30cddb8f07ac919d75140469faab6e0883709da;hp=64400d9eb1426be9ffe546b45855b606bfec05c0;hpb=c99df098ff02de4aeb34a422f2ab7c525e7c37ae;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()