ClusterWorker | poolifier

Hierarchy

AbstractWorker<Worker, Data, Response> +
AbstractWorker<Worker, Data, Response>
- ClusterWorker

Defined in src/worker/cluster-worker.ts:21

@@ -55,9 +57,10 @@ but the minimum number of workers will be guaranteed.

Properties

aliveInterval? +isMain lastTaskTimestamp mainWorker -opts +opts

Methods

@@ -80,7 +83,7 @@ but the minimum number of workers will be guaranteed.

constructor

new ClusterWorker<Data, Response>(fn: ((data: Data) => Response), opts?: WorkerOptions): ClusterWorker<Data, Response>
new ClusterWorker<Data, Response>(fn: WorkerFunction<Data, Response>, opts?: WorkerOptions): ClusterWorker<Data, Response>
Constructs a new poolifier cluster worker.

@@ -95,38 +98,35 @@ but the minimum number of workers will be guaranteed.

Parameters
- -
  fn: ((data: Data) => Response)
  +
  fn: WorkerFunction<Data, Response>
  
  Function processed by the worker when the pool's execution function is invoked.
  -
  -
  - -
    - (data: Data): Response
    - -
      -
      Parameters
      -
      -
      -
      data: Data
      -
      Returns Response

opts: WorkerOptions = {}

Options for the worker.

Returns ClusterWorker<Data, Response>

Properties

`Protected` `Optional` `Readonly` aliveInterval

aliveInterval?: Timeout

Handler Id of the aliveInterval worker alive check.

Handler id of the aliveInterval worker alive check.

Defined in src/worker/abstract-worker.ts:36

`Protected` `Readonly` isMain

isMain: boolean

Whether this is the main worker or not.

`Protected` lastTaskTimestamp

lastTaskTimestamp: number

@@ -134,21 +134,23 @@ but the minimum number of workers will be guaranteed.

Defined in src/worker/abstract-worker.ts:32

`Protected` mainWorker

mainWorker: undefined | null | Worker

`Readonly` opts

opts: WorkerOptions

Defined in src/worker/abstract-worker.ts:50

`Protected` `Readonly` opts

opts: WorkerOptions = ...

Options for the worker.

Defined in src/worker/abstract-worker.ts:51

Methods

@@ -162,11 +164,11 @@ but the minimum number of workers will be guaranteed.

Returns number

Defined in node_modules/.pnpm/@types+node@18.15.11/node_modules/@types/node/async_hooks.d.ts:315

bind

bind<Func>(fn: Func): Func & { asyncResource: AsyncResource }
bind<Func>(fn: Func): Func & {
Â Â Â Â asyncResource: AsyncResource;
}
Binds the given function to execute to this AsyncResource's scope.

The returned function will have an asyncResource property referencing @@ -183,28 +185,28 @@ the AsyncResource to which the function is bound.

Parameters
- -
  fn: Func
  +
  fn: Func
  
  The function to bind to the current AsyncResource.
-
Returns Func & { asyncResource: AsyncResource }
+
Returns Func & {
Â Â Â Â asyncResource: AsyncResource;
}
Inherited from AbstractWorker.bind
- Defined in node_modules/@types/node/ts4.8/async_hooks.d.ts:288

Defined in node_modules/.pnpm/@types+node@18.15.11/node_modules/@types/node/async_hooks.d.ts:288

`Protected` checkAlive

checkAlive(): void
-
Check to see if the worker should be terminated, because its living too long.
+
Checks if the worker should be terminated, because its living too long.

Returns void
Inherited from AbstractWorker.checkAlive
- Defined in src/worker/abstract-worker.ts:144

Defined in src/worker/abstract-worker.ts:156

emitDestroy

emitDestroy(): ClusterWorker<Data, Response>
emitDestroy(): ClusterWorker<Data, Response>
Call all destroy hooks. This should only ever be called once. An error will be thrown if it is called more than once. This must be manually called. If @@ -213,10 +215,10 @@ never be called.

Returns
A reference to asyncResource.

-
Returns ClusterWorker<Data, Response>
+
Returns ClusterWorker<Data, Response>
Inherited from AbstractWorker.emitDestroy
- Defined in node_modules/@types/node/ts4.8/async_hooks.d.ts:311

Defined in node_modules/.pnpm/@types+node@18.15.11/node_modules/@types/node/async_hooks.d.ts:311

`Protected` getMainWorker

Returns Worker

Defined in src/worker/abstract-worker.ts:139

`Protected` handleError

Returns string

Defined in src/worker/cluster-worker.ts:50

`Protected` messageListener

messageListener(value: MessageValue<Data, Worker>, fn: ((data: Data) => Response)): void
messageListener(message: MessageValue<Data, Worker>, fn: WorkerFunction<Data, Response>): void
+
Worker message listener.
+
Parameters
- -
  value: MessageValue<Data, Worker>
- -
  fn: ((data: Data) => Response)
  -
  - -
    - (data: Data): Response
    - -
      -
      Parameters
      -
      +
      message: MessageValue<Data, Worker>
      +
      Message received.
      +
      
      -
      data: Data
      -
      Returns Response
+
fn: WorkerFunction<Data, Response>
+
Function processed by the worker when the pool's execution function is invoked.
+

runInAsyncScope

runInAsyncScope<This, Result>(fn: ((this: This, ...args: any[]) => Result), thisArg?: This, ...args: any[]): Result
runInAsyncScope<This, Result>(fn: ((this: This, ...args: any[]) => Result), thisArg?: This, ...args: any[]): Result
Call the provided function with the provided arguments in the execution context of the async resource. This will establish the context, trigger the AsyncHooks @@ -366,38 +341,38 @@ then restore the original execution context.

Parameters
- -
  fn: ((this: This, ...args: any[]) => Result)
  +
  fn: ((this: This, ...args: any[]) => Result)
  
  The function to call in the execution context of this async resource.
  - - (this: This, ...args: any[]): Result
    - (this: This, ...args: any[]): Result
    - Parameters
      
      -
      this: This
      +
      this: This
      
      Rest ...args: any[]
      -
      Returns Result

`Optional` thisArg: This

The receiver to be used for the function call.

`Rest` ...args: any[]

Optional arguments to pass to the function.

Template

Template

Author

Since

Type Parameters

Data = unknown

Data = unknown

Response = unknown

Response = unknown

Hierarchy

Properties

Methods

constructor

Parameters

fn: ((data: Data) => Response)

fn: WorkerFunction<Data, Response>

Parameters

data: Data

Returns Response

opts: WorkerOptions = {}

Returns ClusterWorker<Data, Response>

Properties

Protected Optional Readonly aliveInterval

Protected Readonly isMain

Protected lastTaskTimestamp

Protected mainWorker

Readonly opts

Protected Readonly opts

Methods

Returns number

bind

Parameters

fn: Func

fn: Func

Returns Func & { asyncResource: AsyncResource }

Protected checkAlive

Returns void

emitDestroy

Returns

Returns ClusterWorker<Data, Response>

Protected getMainWorker

Returns Worker

Protected handleError

Returns string

Protected messageListener

Parameters

value: MessageValue<Data, Worker>

fn: ((data: Data) => Response)

Parameters

message: MessageValue<Data, Worker>

data: Data

Returns Response

fn: WorkerFunction<Data, Response>

Returns void

Protected run

Parameters

fn: ((data?: Data) => Response)

fn: WorkerSyncFunction<Data, Response>

Parameters

Optional data: Data

Returns Response

value: MessageValue<Data, unknown>

message: MessageValue<Data, unknown>

Returns void

Protected runAsync

Parameters

fn: ((data?: Data) => Promise<Response>)

fn: WorkerAsyncFunction<Data, Response>

Parameters

Optional data: Data

Returns Promise<Response>

value: MessageValue<Data, unknown>

message: MessageValue<Data, unknown>

Returns void

runInAsyncScope

Parameters

fn: ((this: This, ...args: any[]) => Result)

fn: ((this: This, ...args: any[]) => Result)

Parameters

this: This

`Protected` `Optional` `Readonly` aliveInterval

`Protected` `Readonly` isMain

`Protected` lastTaskTimestamp

`Protected` mainWorker

`Readonly` opts

`Protected` `Readonly` opts

`Protected` checkAlive

`Protected` getMainWorker

`Protected` handleError

`Protected` messageListener

`Protected` run

`Optional` data: Data

`Protected` runAsync

`Optional` data: Data

`Rest` ...args: any[]

`Optional` thisArg: This

`Optional` thisArg: This

`Rest` ...args: any[]

`Protected` sendToMainWorker

`Static` bind

`Optional` thisArg: ThisArg