X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FClusterWorker.html;h=c0f5daf0f9b4828c6278913c5fd89600a532daba;hb=224d008191f52fa20b93e1ba67919569f8d6e315;hp=aaea291ecbf9e418e4ebff54c88e5ce8916b6976;hpb=dea42379cfdbcf1c1c9800df7c097eab484ebc07;p=poolifier.git diff --git a/docs/classes/ClusterWorker.html b/docs/classes/ClusterWorker.html index aaea291e..c0f5daf0 100644 --- a/docs/classes/ClusterWorker.html +++ b/docs/classes/ClusterWorker.html @@ -1,13 +1,13 @@ -ClusterWorker | poolifier - v4.0.15

Class ClusterWorker<Data, Response>

A cluster worker used by a poolifier ClusterPool.

+ClusterWorker | poolifier - v4.0.15

Class ClusterWorker<Data, Response>

A cluster worker used by a poolifier ClusterPool.

When this worker is inactive for more than the given maxInactiveTime, it will send a termination request to its main worker.

If you use a DynamicClusterPool the extra workers that were created will be terminated, but the minimum number of workers will be guaranteed.

-

Author

Christopher Quadflieg

-

Since

2.0.0

-

Type Parameters

  • Data = unknown

    Type of data this worker receives from pool's execution. This can only be structured-cloneable data.

    +

    Christopher Quadflieg

    +

    2.0.0

    +

Type Parameters

  • Data = unknown

    Type of data this worker receives from pool's execution. This can only be structured-cloneable data.

  • Response = unknown

    Type of response the worker sends back to the main worker. This can only be structured-cloneable data.

    -

Hierarchy (view full)

Constructors

Hierarchy (view full)

Constructors

Properties

activeInterval? isMain lastTaskTimestamp @@ -31,53 +31,53 @@ but the minimum number of workers will be guaranteed.

sendTaskFunctionsPropertiesToMainWorker sendToMainWorker setDefaultTaskFunction -

Constructors

Constructors

Properties

activeInterval?: Timeout

Handler id of the activeInterval worker activity check.

-
isMain: undefined | boolean

Whether this is the main worker or not.

-
lastTaskTimestamp: number

Timestamp of the last task processed by this worker.

-
opts: WorkerOptions = DEFAULT_WORKER_OPTIONS

Options for the worker.

-
statistics?: WorkerStatistics

Performance statistics computation requirements.

-
taskFunctions: Map<string, TaskFunctionObject<Data, Response>>

Task function object(s) processed by the worker when the pool's execution function is invoked.

-

Accessors

Methods

Returns ClusterWorker<Data, Response>

Properties

activeInterval?: Timeout

Handler id of the activeInterval worker activity check.

+
isMain: undefined | boolean

Whether this is the main worker or not.

+
lastTaskTimestamp: number

Timestamp of the last task processed by this worker.

+
opts: WorkerOptions = DEFAULT_WORKER_OPTIONS

Options for the worker.

+
statistics?: WorkerStatistics

Performance statistics computation requirements.

+
taskFunctions: Map<string, TaskFunctionObject<Data, Response>>

Task function object(s) processed by the worker when the pool's execution function is invoked.

+

Accessors

Methods

  • Handles an error and convert it to a string so it can be sent back to the main worker.

    Parameters

    • error: string | Error

      The error raised by the worker.

    Returns string

    The error message.

    -
  • Handles the ready message sent by the main worker.

    +

Returns void

Returns void

Returns void

Returns void

Returns void

Returns void

Returns void

\ No newline at end of file +
\ No newline at end of file