ClusterWorker | poolifier

+ClusterWorker | poolifier

@@ -83,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: ((data: Data) => Response), opts?: WorkerOptions): ClusterWorker<Data, Response>
Constructs a new poolifier cluster worker.

@@ -98,28 +98,28 @@ but the minimum number of workers will be guaranteed.

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

Returns Response

opts: WorkerOptions = {}

Options for the worker.

Returns ClusterWorker<Data, Response>

Properties

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

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

`Protected` `Readonly` isMain

isMain: boolean

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

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

`Protected` lastTaskTimestamp

lastTaskTimestamp: number

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

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

`Protected` mainWorker

mainWorker: undefined | null | Worker

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

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

`Protected` `Readonly` opts

opts: WorkerOptions = ...

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

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

Methods

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

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 @@ -196,10 +196,10 @@ 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/.pnpm/@types+node@18.15.11/node_modules/@types/node/async_hooks.d.ts:288

@@ -213,11 +213,11 @@ the AsyncResource to which the function is bound.

Returns void

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

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 @@ -226,7 +226,7 @@ never be called.

Returns
A reference to asyncResource.

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

@@ -242,7 +242,7 @@ never be called.

Returns Worker

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

`Protected` handleError

Returns string

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

`Protected` messageListener

messageListener(message: MessageValue<Data, Worker>, fn: ((data: Data) => Response)): void
messageListener(message: MessageValue<Data, Worker>, fn: ((data: Data) => Response)): void
Worker message listener.

@@ -270,32 +270,32 @@ never be called.

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

Returns Response

Returns void

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

`Protected` run

run(fn: ((data?: Data) => Response), message: MessageValue<Data, unknown>): void
run(fn: ((data?: Data) => Response), message: MessageValue<Data, unknown>): void
Runs the given function synchronously.

@@ -303,32 +303,32 @@ never be called.

Parameters
- -
  fn: ((data?: Data) => Response)
  +
  fn: ((data?: Data) => Response)
  
  Function that will be executed.
  - - (data?: Data): Response
    - (data?: Data): Response
    - Parameters
      
      -
      Optional data: Data
      -
      Returns Response
+
Returns Response

message: MessageValue<Data, unknown>

Input data for the given function.

Returns void

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

`Protected` runAsync

runAsync(fn: ((data?: Data) => Promise<Response>), message: MessageValue<Data, unknown>): void
runAsync(fn: ((data?: Data) => Promise<Response>), message: MessageValue<Data, unknown>): void
Runs the given function asynchronously.

@@ -336,32 +336,32 @@ never be called.

Parameters
- -
  fn: ((data?: Data) => Promise<Response>)
  +
  fn: ((data?: Data) => Promise<Response>)
  
  Function that will be executed.
  - - (data?: Data): Promise<Response>
    - (data?: Data): Promise<Response>
    - Parameters
      
      -
      Optional data: Data
      -
      Returns Promise<Response>
+
Returns Promise<Response>

message: MessageValue<Data, unknown>

Input data for the given function.

Returns void

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

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 @@ -381,38 +381,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.

Returns Result

`Protected` sendToMainWorker

sendToMainWorker(message: MessageValue<Response, unknown>): void
sendToMainWorker(message: MessageValue<Response, unknown>): void
Inherit Doc
@@ -420,11 +420,11 @@ then restore the original execution context.

Parameters
- -
  message: MessageValue<Response, unknown>
+
message: MessageValue<Response, unknown>

Returns void

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

triggerAsyncId

`Static` bind

bind<Func, ThisArg>(fn: Func, type?: string, thisArg?: ThisArg): Func & {
Â Â Â Â asyncResource: AsyncResource;
}
bind<Func, ThisArg>(fn: Func, type?: string, thisArg?: ThisArg): Func & {
Â Â Â Â asyncResource: AsyncResource;
}
Binds the given function to the current execution context.

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

Type Parameters
- -
  Func extends ((this: ThisArg, ...args: any[]) => any)
- ThisArg

Parameters

-
fn: Func
+
fn: Func

The function to bind to the current execution context.
@@ -467,15 +467,16 @@ the AsyncResource to which the function is bound.

An optional name to associate with the underlying AsyncResource.
-
Optional thisArg: ThisArg

Returns Func & {
Â Â Â Â asyncResource: AsyncResource;
}

- + +

Generated using TypeDoc

\ No newline at end of file +

\ No newline at end of file

constructor

Parameters

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

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

Parameters

data: Data

Returns Response

data: Data

Parameters

fn: Func

fn: Func

Parameters

data: Data

Returns Response

Parameters

`Optional` data: Data

Returns Response

Parameters

`Optional` data: Data

Returns Promise<Response>

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

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

Parameters

this: This

this: This

`Rest` ...args: any[]

Returns Result

Type Parameters

Func extends ((this: ThisArg, ...args: any[]) => any)

Func extends ((this: ThisArg, ...args: any[]) => any)

ThisArg

Settings

Member Visibility

Theme

constructor

Parameters

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

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

Parameters

data: Data

Returns Response

data: Data

fn: Func

fn: Func

Parameters

data: Data

Returns Response

Parameters

Optional data: Data

Returns Response

Parameters

Optional data: Data

Returns Promise<Response>

Parameters

this: This

this: This

Rest ...args: any[]

Returns Result

Func extends ((this: ThisArg, ...args: any[]) => any)

ThisArg

`Optional` data: Data

`Optional` data: Data

`Rest` ...args: any[]