repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
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 { 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.
/**
* Callback invoked when the worker has started successfully.
@@
-154,6
+154,11
@@
export interface WorkerInfo {
* Ready flag.
*/
ready: boolean
* 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.
*/
/**
* Task function names.
*/
@@
-206,7
+211,7
@@
export interface IWorker {
*/
readonly threadId?: number
/**
*/
readonly threadId?: number
/**
- * Registers an event
listen
er.
+ * Registers an event
handl
er.
*
* @param event - The event.
* @param handler - The event handler.
*
* @param event - The event.
* @param handler - The event handler.
@@
-220,7
+225,7
@@
export interface IWorker {
| ExitHandler<this>
) => void
/**
| ExitHandler<this>
) => void
/**
- * Registers once an event
listen
er.
+ * Registers once an event
handl
er.
*
* @param event - The event.
* @param handler - The 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.
* Registers a worker event handler.
*
* @param event - The event.
- * @param
listener - The event listen
er.
+ * @param
handler - The event handl
er.
*/
readonly registerWorkerEventHandler: (
event: string,
*/
readonly registerWorkerEventHandler: (
event: string,
-
listen
er:
+
handl
er:
| OnlineHandler<Worker>
| MessageHandler<Worker>
| ErrorHandler<Worker>
| 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.
* Registers once a worker event handler.
*
* @param event - The event.
- * @param
listener - The event listen
er.
+ * @param
handler - The event handl
er.
*/
readonly registerOnceWorkerEventHandler: (
event: string,
*/
readonly registerOnceWorkerEventHandler: (
event: string,
-
listen
er:
+
handl
er:
| OnlineHandler<Worker>
| MessageHandler<Worker>
| ErrorHandler<Worker>
| OnlineHandler<Worker>
| MessageHandler<Worker>
| ErrorHandler<Worker>