chore: v3.1.13

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

diff --git a/src/pools/worker.ts b/src/pools/worker.ts
index da4cf172d98ee4fcc3384fe4f11bc50800f4a378..c7a9dcb3cecba710cf62a345f4efd9f029d2f2fb 100644 (file)
--- a/src/pools/worker.ts
+++ b/src/pools/worker.ts
@@ -1,7 +1,7 @@
-import type { MessageChannel } from 'node:worker_threads'
+import type { MessageChannel, WorkerOptions } from 'node:worker_threads'
 import type { EventEmitter } from 'node:events'
-import type { CircularArray } from '../circular-array'
-import type { Task } from '../utility-types'
+import type { CircularArray } from '../circular-array.js'
+import type { Task } from '../utility-types.js'
 
 /**
  * Callback invoked when the worker has started successfully.
@@ -154,6 +154,11 @@ export interface WorkerInfo {
    * Ready flag.
    */
   ready: boolean
+  /**
+   * Stealing flag.
+   * This flag is set to `true` when worker node is stealing tasks from another worker node.
+   */
+  stealing: boolean
   /**
    * Task function names.
    */
@@ -206,7 +211,7 @@ export interface IWorker {
    */
   readonly threadId?: number
   /**
-   * Registers an event listener.
+   * Registers an event handler.
    *
    * @param event - The event.
    * @param handler - The event handler.
@@ -220,7 +225,7 @@ export interface IWorker {
     | ExitHandler<this>
   ) => void
   /**
-   * Registers once an event listener.
+   * Registers once an event handler.
    *
    * @param event - The event.
    * @param handler - The event handler.
@@ -348,11 +353,11 @@ export interface IWorkerNode<Worker extends IWorker, Data = unknown>
    * Registers a worker event handler.
    *
    * @param event - The event.
-   * @param listener - The event listener.
+   * @param handler - The event handler.
    */
   readonly registerWorkerEventHandler: (
     event: string,
-    listener:
+    handler:
     | OnlineHandler<Worker>
     | MessageHandler<Worker>
     | ErrorHandler<Worker>
@@ -362,11 +367,11 @@ export interface IWorkerNode<Worker extends IWorker, Data = unknown>
    * Registers once a worker event handler.
    *
    * @param event - The event.
-   * @param listener - The event listener.
+   * @param handler - The event handler.
    */
   readonly registerOnceWorkerEventHandler: (
     event: string,
-    listener:
+    handler:
     | OnlineHandler<Worker>
     | MessageHandler<Worker>
     | ErrorHandler<Worker>