-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.
* 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.
*/
*/
readonly threadId?: number
/**
- * Registers an event listener.
+ * Registers an event handler.
*
* @param event - The event.
* @param handler - The event handler.
| ExitHandler<this>
) => void
/**
- * Registers once an event listener.
+ * Registers once an event handler.
*
* @param event - The event.
* @param handler - The event handler.
* 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>
* 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>