X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=inline;f=src%2Fpools%2Fpool.ts;h=2cdf9b748db6350b0bfa7c9e64aedd8b32b296cf;hb=243a550a93e278669fe5602aeba92dc8ba11260e;hp=f24d79e41e01dfba297821ea88acc22066052550;hpb=ffe8ca52bf1a05f68a0c939d16f15b6b54028be9;p=poolifier.git

diff --git a/src/pools/pool.ts b/src/pools/pool.ts
index f24d79e4..2cdf9b74 100644
--- a/src/pools/pool.ts
+++ b/src/pools/pool.ts
@@ -29,6 +29,18 @@ export const PoolEvents = Object.freeze({
  */
 export type PoolEvent = keyof typeof PoolEvents
 
+/**
+ * Worker tasks queue options.
+ */
+export interface TasksQueueOptions {
+  /**
+   * Maximum number of tasks that can be executed concurrently on a worker.
+   *
+   * @defaultValue 1
+   */
+  concurrency?: number
+}
+
 /**
  * Options for a poolifier pool.
  */
@@ -70,6 +82,13 @@ export interface PoolOptions<Worker extends IWorker> {
    * @defaultValue false
    */
   enableTasksQueue?: boolean
+  /**
+   * Pool worker tasks queue options.
+   *
+   * @experimental
+   * @defaultValue \{ concurrency: 1 \}
+   */
+  tasksQueueOptions?: TasksQueueOptions
 }
 
 /**