X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Finterfaces%2FIWorkerNode.html;h=4542f53e87f34a543ca4d6f923dfce9f648919f5;hb=42283971c52896a642fafa9fd351da3ef645b7f5;hp=8412566a8db469b85de4fb952372dcc14e161a22;hpb=926bdbf304ff660de1360e348517038a837c505f;p=poolifier.git diff --git a/docs/interfaces/IWorkerNode.html b/docs/interfaces/IWorkerNode.html index 8412566a..4542f53e 100644 --- a/docs/interfaces/IWorkerNode.html +++ b/docs/interfaces/IWorkerNode.html @@ -1,7 +1,7 @@ -
Internal
Generated using TypeDoc
Generated using TypeDoc
Worker node interface.
+- Preparing search index...
- The search index is not available
poolifier - v3.1.16Interface IWorkerNode<Worker, Data>
Internal
Worker node interface.
    clearTasksQueue: (() => void);
    deleteTaskFunctionWorkerUsage: ((name) => boolean);
    dequeueTask: (() => undefined | Task<Data>);
    enqueueTask: ((task) => number);
    getTaskFunctionWorkerUsage: ((name) => undefined | WorkerUsage);
    hasBackPressure: (() => boolean);
    info: WorkerInfo;
    messageChannel?: MessageChannel;
    popTask: (() => undefined | Task<Data>);
    registerOnceWorkerEventHandler: ((event, handler) => void);
    registerWorkerEventHandler: ((event, handler) => void);
    resetUsage: (() => void);
    strategyData?: StrategyData;
    tasksQueueBackPressureSize: number;
    tasksQueueSize: (() => number);
    terminate: (() => Promise<void>);
    unshiftTask: ((task) => number);
    usage: WorkerUsage;
    worker: Worker;
    [captureRejectionSymbol]?(error, event, ...args): void;
    addListener(eventName, listener): this;
    emit(eventName, ...args): boolean;
    eventNames(): (string | symbol)[];
    getMaxListeners(): number;
    listenerCount(eventName, listener?): number;
    listeners(eventName): Function[];
    off(eventName, listener): this;
    on(eventName, listener): this;
    once(eventName, listener): this;
    prependListener(eventName, listener): this;
    prependOnceListener(eventName, listener): this;
    rawListeners(eventName): Function[];
    removeAllListeners(event?): this;
    removeListener(eventName, listener): this;
    setMaxListeners(n): this;
}
Type Parameters
Worker extends IWorker
Type of worker.
Data = unknown
Type of data sent to the worker. This can only be structured-cloneable data.
-Hierarchy
Index
Properties
Hierarchy
Index
Properties
Properties
Readonly
clearClears tasks queue.
Type declaration
Clears tasks queue.
-Returns void
Readonly
deleteDeletes task function worker usage statistics.
+Returns void
Readonly
deleteDeletes task function worker usage statistics.
Type declaration
Deletes task function worker usage statistics.
Parameters
name: string
The task function name.
Returns boolean
true
if the task function worker usage statistics were deleted,false
otherwise.Param: name
The task function name.
Returns
-true
if the task function worker usage statistics were deleted,false
otherwise.Readonly
dequeueDequeue task.
+Readonly
dequeueDequeue task.
Type declaration
Dequeue task.
Returns undefined | Task<Data>
The dequeued task.
Returns
The dequeued task.
-Readonly
enqueueEnqueue task.
+Readonly
enqueueEnqueue task.
Type declaration
Enqueue task.
Parameters
task: Task<Data>
The task to queue.
Returns number
The tasks queue size.
Param: task
The task to queue.
Returns
The tasks queue size.
-Readonly
getGets task function worker usage statistics.
+Readonly
getGets task function worker usage statistics.
Type declaration
Gets task function worker usage statistics.
Parameters
name: string
The task function name.
Returns undefined | WorkerUsage
The task function worker usage statistics if the task function worker usage statistics are initialized,
undefined
otherwise.Param: name
The task function name.
Returns
The task function worker usage statistics if the task function worker usage statistics are initialized,
-undefined
otherwise.Readonly
hasWhether the worker node has back pressure (i.e. its tasks queue is full).
+Readonly
hasWhether the worker node has back pressure (i.e. its tasks queue is full).
Type declaration
Whether the worker node has back pressure (i.e. its tasks queue is full).
Returns boolean
true
if the worker node has back pressure,false
otherwise.Returns
-true
if the worker node has back pressure,false
otherwise.Readonly
infoWorker info.
-Optional
Readonly
messageMessage channel (worker thread only).
-Readonly
popPops a task from the tasks queue.
+Readonly
infoWorker info.
+Optional
Readonly
messageMessage channel (worker thread only).
+Readonly
popPops a task from the tasks queue.
Type declaration
Pops a task from the tasks queue.
Returns undefined | Task<Data>
The popped task.
Returns
The popped task.
-Readonly
registerRegisters once a worker event handler.
+Readonly
registerRegisters once a worker event handler.
Type declaration
Registers once a worker event handler.
Parameters
event: string
The event.
-handler: EventHandler<Worker>
The event handler.
+handler: EventHandler<Worker>
The event handler.
Returns void
Param: event
The event.
Param: handler
The event handler.
-Readonly
registerRegisters a worker event handler.
+Readonly
registerRegisters a worker event handler.
Type declaration
Registers a worker event handler.
Parameters
event: string
The event.
-handler: EventHandler<Worker>
The event handler.
+handler: EventHandler<Worker>
The event handler.
Returns void
Param: event
The event.
Param: handler
The event handler.
-Readonly
resetResets usage statistics.
+Readonly
resetResets usage statistics.
Type declaration
Resets usage statistics.
-Returns void
Optional
strategyWorker choice strategy data. +
Returns void
Optional
strategyWorker choice strategy data. This is used to store data that are specific to the worker choice strategy.
-tasks Queue Back Pressure Size
Tasks queue back pressure size. +
tasks Queue Back Pressure Size
Tasks queue back pressure size. This is the number of tasks that can be enqueued before the worker node has back pressure.
-Readonly
tasksTasks queue size.
+Readonly
tasksTasks queue size.
Type declaration
Tasks queue size.
Returns number
The tasks queue size.
Returns
The tasks queue size.
-Readonly
terminateTerminates the worker node.
+Readonly
terminateTerminates the worker node.
Type declaration
Terminates the worker node.
-Returns Promise<void>
Readonly
unshiftPrepends a task to the tasks queue.
+Returns Promise<void>
Readonly
unshiftPrepends a task to the tasks queue.
Type declaration
Prepends a task to the tasks queue.
Parameters
task: Task<Data>
The task to prepend.
Returns number
The tasks queue size.
Param: task
The task to prepend.
Returns
The tasks queue size.
-Readonly
usageWorker usage statistics.
-Readonly
workerWorker.
-Methods
Optional
[captureParameters
error: Error
event: string
Rest
...args: any[]Returns void
add Listener
Alias for
+emitter.on(eventName, listener)
.Readonly
usageWorker usage statistics.
+Readonly
workerWorker.
+Methods
Optional
[captureParameters
error: Error
event: string
Rest
...args: any[]Returns void
add Listener
Alias for
emitter.on(eventName, listener)
.Parameters
eventName: string | symbol
listener: ((...args) => void)
Parameters
Rest
...args: any[]Returns void
Returns this
Since
v0.1.26
emit
Synchronously calls each of the listeners registered for the event named
@@ -215,4 +215,4 @@ memory leaks. TheeventName
, in the order they were registered, passing the supplied arguments to each.emitter.setMaxListeners()
method allows the limit modified for this specificEventEmitter
instance. The value can be set toInfinity
(or0
) to indicate an unlimited number of listeners.Returns a reference to the
EventEmitter
, so that calls can be chained.Parameters
n: number
Returns this
Since
v0.3.5
-Settings
Member Visibility
Theme
On This Page