AbstractWorker | poolifier

X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FAbstractWorker.html;h=df85f6680ee4b5899780ee0f36af115abac21d0c;hb=fbc22127e53d3ec0ecbd38ecea25fb92ebef50e7;hp=6c2de6b9626f2ec5395f1a80e5f793ac82ad0502;hpb=9954c636f2caafac0b2bf0289059788679fd3053;p=poolifier.git diff --git a/docs/classes/AbstractWorker.html b/docs/classes/AbstractWorker.html index 6c2de6b9..df85f668 100644 --- a/docs/classes/AbstractWorker.html +++ b/docs/classes/AbstractWorker.html @@ -1,4 +1,4 @@ -AbstractWorker | poolifier

+AbstractWorker | poolifier

@@ -22,28 +22,28 @@

Type Parameters

-
MainWorker extends Worker | MessagePort
+
MainWorker extends Worker | MessagePort

Type of main worker.
-
Data = unknown
+
Data = unknown

Type of data this worker receives from pool's execution. This can only be serializable data.
-
Response = unknown
+
Response = unknown

Type of response the worker sends back to the main worker. This can only be serializable data.

Hierarchy

AsyncResource +
AsyncResource
- AbstractWorker
  - ClusterWorker
  - ThreadWorker

@@ -51,40 +51,40 @@

Constructors

constructor +

constructor

Properties

aliveInterval? -isMain -lastTaskTimestamp -mainWorker -opts +

aliveInterval? +isMain +lastTaskTimestamp +mainWorker +opts

Constructors

constructor

new AbstractWorker<MainWorker, Data, Response>(type: string, isMain: boolean, fn: WorkerFunction<Data, Response>, mainWorker: undefined | null | MainWorker, opts?: WorkerOptions): AbstractWorker<MainWorker, Data, Response>

new AbstractWorker<MainWorker, Data, Response>(type, isMain, fn, mainWorker, opts?): AbstractWorker<MainWorker, Data, Response>
Constructs a new poolifier worker.

@@ -92,81 +92,81 @@
Type Parameters
- -
  MainWorker extends Worker | MessagePort
- -
  Data = unknown
- -
  Response = unknown

Response = unknown

Parameters

-
type: string
+
type: string

The type of async event.
-
isMain: boolean
+
isMain: boolean

Whether this is the main worker or not.
-
fn: WorkerFunction<Data, Response>
+
fn: WorkerFunction<Data, Response>

Function processed by the worker when the pool's execution function is invoked.
-
mainWorker: undefined | null | MainWorker
+
mainWorker: undefined | null | MainWorker

Reference to main worker.
-
opts: WorkerOptions = ...
+
opts: WorkerOptions = ...

Options for the worker.

Returns AbstractWorker<MainWorker, Data, Response>

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

Properties

`Protected` `Optional` `Readonly` aliveInterval

aliveInterval?: Timeout

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.

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

`Protected` lastTaskTimestamp

lastTaskTimestamp: number

Timestamp of the last task processed by this worker.

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

`Protected` mainWorker

mainWorker: undefined | null | MainWorker

Reference to main worker.

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

asyncId

asyncId(): number

asyncId(): number
Returns
The unique asyncId assigned to the resource.
@@ -175,10 +175,10 @@
Inherited from AsyncResource.asyncId
- 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 & {
Â Â Â Â asyncResource: AsyncResource;
}
Binds the given function to execute to this AsyncResource's scope.

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

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

Func extends ((...args) => any)

Parameters

-
fn: Func
+
fn: Func

The function to bind to the current AsyncResource.

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

`Protected` checkAlive

checkAlive(): void

checkAlive(): void
Checks if the worker should be terminated, because its living too long.

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

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

`Private` checkFunctionInput

checkFunctionInput(fn: WorkerFunction<Data, Response>): void

checkFunctionInput(fn): void
Checks if the fn parameter is passed to the constructor.

@@ -223,29 +223,29 @@ the AsyncResource to which the function is bound.

Parameters
- -
  fn: WorkerFunction<Data, Response>
  +
  fn: WorkerFunction<Data, Response>
  
  The function that should be defined.

Returns void

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

`Private` checkWorkerOptions

checkWorkerOptions(opts: WorkerOptions): void

checkWorkerOptions(opts): void
Parameters
- -
  opts: WorkerOptions
+
opts: WorkerOptions

Returns void

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

emitDestroy

emitDestroy(): AbstractWorker<MainWorker, Data, Response>

emitDestroy(): AbstractWorker<MainWorker, 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 @@ -254,26 +254,26 @@ never be called.

Returns
A reference to asyncResource.

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

`Protected` getMainWorker

getMainWorker(): MainWorker

getMainWorker(): MainWorker
Returns the main worker.

Returns
Reference to the main worker.

-
Returns MainWorker
+
Returns MainWorker
- Defined in src/worker/abstract-worker.ts:139

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

`Protected` handleError

handleError(e: string | Error): string

handleError(e): string
Handles an error and convert it to a string so it can be sent back to the main worker.
@@ -283,16 +283,16 @@ never be called.

Parameters
- -
  e: string | Error
  +
  e: string | Error
  
  The error raised by the worker.
Returns string
- Defined in src/worker/abstract-worker.ts:171

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

`Protected` messageListener

messageListener(message: MessageValue<Data, MainWorker>, fn: WorkerFunction<Data, Response>): void

messageListener(message, fn): void
Worker message listener.

@@ -300,20 +300,20 @@ never be called.

Parameters
- -
  message: MessageValue<Data, MainWorker>
  +
  message: MessageValue<Data, MainWorker>
  
  Message received.
- -
  fn: WorkerFunction<Data, Response>
  +
  fn: WorkerFunction<Data, Response>
  
  Function processed by the worker when the pool's execution function is invoked.
Returns void
- Defined in src/worker/abstract-worker.ts:89

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

`Protected` run

run(fn: WorkerSyncFunction<Data, Response>, message: MessageValue<Data, unknown>): void

run(fn, message): void
Runs the given function synchronously.

@@ -321,20 +321,20 @@ never be called.

Parameters
- -
  fn: WorkerSyncFunction<Data, Response>
  +
  fn: WorkerSyncFunction<Data, Response>
  
  Function that will be executed.
- -
  message: MessageValue<Data, unknown>
  +
  message: MessageValue<Data, unknown>
  
  Input data for the given function.
Returns void
- Defined in src/worker/abstract-worker.ts:181

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

`Protected` runAsync

runAsync(fn: WorkerAsyncFunction<Data, Response>, message: MessageValue<Data, unknown>): void

runAsync(fn, message): void
Runs the given function asynchronously.

@@ -342,20 +342,20 @@ never be called.

Parameters
- -
  fn: WorkerAsyncFunction<Data, Response>
  +
  fn: WorkerAsyncFunction<Data, Response>
  
  Function that will be executed.
- -
  message: MessageValue<Data, unknown>
  +
  message: MessageValue<Data, unknown>
  
  Input data for the given function.
Returns void
- Defined in src/worker/abstract-worker.ts:208

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

runInAsyncScope

runInAsyncScope<This, Result>(fn: ((this: This, ...args: any[]) => Result), thisArg?: This, ...args: any[]): Result

runInAsyncScope<This, Result>(fn, thisArg?, ...args): 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 @@ -368,45 +368,45 @@ then restore the original execution context.

Type Parameters
- -
  This
- -
  Result

Result

Parameters

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

The function to call in the execution context of this async resource.
- -
  - (this: This, ...args: any[]): Result

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

triggerAsyncId

triggerAsyncId(): number

triggerAsyncId(): number
Returns
The same triggerAsyncId that is passed to the AsyncResource constructor.
@@ -432,10 +432,10 @@ then restore the original execution context.

Inherited from AsyncResource.triggerAsyncId
- Defined in node_modules/.pnpm/@types+node@18.15.11/node_modules/@types/node/async_hooks.d.ts:320

`Static` bind

bind<Func, ThisArg>(fn: Func, type?: string, thisArg?: ThisArg): Func & {
Â Â Â Â asyncResource: AsyncResource;
}

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

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

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

ThisArg

Parameters

-
fn: Func
+
fn: Func

The function to bind to the current execution context.
-
Optional type: string
+
Optional type: string

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