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
the resource is left to be collected by the GC then the destroy hooks will
never be called.
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
@@ -401,78 +360,77 @@ then restore the original execution context.
Since
v9.6.0
-
+
Type Parameters
-
+
-
This
+
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
+
+
(this, ...args): Result
Parameters
-
this: This
+
this: This
-
Rest...args: any[]
-
Returns Result
+
Rest...args: any[]
+
Returns Result
-
Optional thisArg: This
+
OptionalthisArg: This
The receiver to be used for the function call.
-
Rest...args: any[]
+
Rest...args: any[]
Optional arguments to pass to the function.
-
Returns Result
-
+
Defined in node_modules/.pnpm/@types+node@18.15.13/node_modules/@types/node/async_hooks.d.ts:303
Base class containing some shared logic for all poolifier workers.
+Base class that implements some shared logic for all poolifier workers.
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
@@ -49,135 +51,133 @@
constructor
+constructor
alivealive
asyncasync
+
+
-
-
-
-
-
-
+
-
-
-
+Defined in src/worker/abstract-worker.ts:46
+
alive
-alive
+
+is
+
-
+Defined in src/worker/abstract-worker.ts:48
+
last
+last
-
+Defined in src/worker/abstract-worker.ts:32
+
main
-
-opts: WorkerOptions
+Defined in src/worker/abstract-worker.ts:50
+
+opts: WorkerOptions = ...
+Defined in src/worker/abstract-worker.ts:51
+
-
+Defined in node_modules/.pnpm/@types+node@18.15.13/node_modules/@types/node/async_hooks.d.ts:315
+
-
-
-
-
+Defined in node_modules/.pnpm/@types+node@18.15.13/node_modules/@types/node/async_hooks.d.ts:288
+
-
+Defined in src/worker/abstract-worker.ts:95
+
-
+Defined in src/worker/abstract-worker.ts:83
+
-
+Defined in node_modules/.pnpm/@types+node@18.15.13/node_modules/@types/node/async_hooks.d.ts:311
+
-
+Defined in src/worker/abstract-worker.ts:139
+
-
+Defined in src/worker/abstract-worker.ts:113
+
-
+Defined in src/worker/abstract-worker.ts:181
+
-
+Defined in src/worker/abstract-worker.ts:208
+
+
-
-
-
-
+
+
-
-
-
-
+Defined in node_modules/.pnpm/@types+node@18.15.13/node_modules/@types/node/async_hooks.d.ts:303
+
-
+Defined in node_modules/.pnpm/@types+node@18.15.13/node_modules/@types/node/async_hooks.d.ts:273
+
+
-
-
Constructors
-Properties
-Methods
-Constructors
-constructor
--- new
+
+- new
-
+
-
-
+-
-
Constructs a new poolifier worker.
Type Parameters
-+-
-
+
MainWorker extends Worker | MessagePort
MainWorker extends Worker | MessagePort
Data = unknown
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: ((data: Data) => Response)
+fn: WorkerFunction<Data, Response>
Function processed by the worker when the pool's
-executionfunction is invoked.--
-
-- (data: Data): Response
--
-
-
-
Parameters
---
-
data: Data
Returns Response
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>
Properties
-
-ProtectedOptionalReadonlyaliveHandler Id of the
+aliveIntervalworker alive check.Handler id of the
+aliveIntervalworker alive check.
+ProtectedReadonlyisWhether this is the main worker or not.
-ProtectedlastTimestamp of the last task processed by this worker.
-Protectedmain
-Readonlyopts
+ProtectedReadonlyoptsOptions for the worker.
Methods
-async
--- async
+
+- async
-
-
-
-
Returns
The unique
-asyncIdassigned to the resource.Returns number
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
asyncResourceproperty referencing @@ -185,214 +185,173 @@ theAsyncResourceto which the function is bound.Since
v14.8.0, v12.19.0
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 }
-Protectedcheck-- check
+
+- check
-
-
+- Defined in src/worker/abstract-worker.ts:156
+
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
-
-Privatecheck-- check
+
+- check
-
-
-
-
+
Check if the
+fnparameter is passed to the constructor.Checks if the
fnparameter is passed to the constructor.Parameters
fn: ((data: Data) => Response)
+fn: WorkerFunction<Data, Response>
The function that should be defined.
---
-
-- (data: Data): Response
--
-
-
-
Parameters
---
-
data: Data
Returns Response
Returns void
-Privatecheck-- check
+
+- check
-
-
-
+
Parameters
opts: WorkerOptions
opts: WorkerOptions
Returns void
emit
--- emit
+
+- emit
-
Call all
- -destroyhooks. 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 the resource is left to be collected by the GC then thedestroyhooks will never be called.Returns
A reference to
asyncResource.Returns AbstractWorker<MainWorker, Data, Response>
-Protectedget-- get
+
+- get
-
Returns the main worker.
- -Returns
Reference to the main worker.
Returns MainWorker
-Protectedhandle-- handle
+
+- handle
-
-
-
-
-
Handle an error and convert it to a string so it can be sent back to the main worker.
- -Returns
Message of the error.
+Handles an error and convert it to a string so it can be sent back to the main worker.
Parameters
e: string | Error
+e: string | Error
The error raised by the worker.
Returns string
+
-Protectedmessage-- message
+
+- message
-
+
-
-
--
-
+
Worker message listener.
+Parameters
value: MessageValue<Data, MainWorker>
fn: ((data: Data) => Response)
---
-
-- (data: Data): Response
--
-
-
-
Parameters
-+-
-
message: MessageValue<Data, MainWorker>
+Message received.
+data: Data
Returns Response
fn: WorkerFunction<Data, Response>
+Function processed by the worker when the pool's
+executionfunction is invoked.Returns void
-Protectedrun-- run(fn: ((data?: Data) => Response), value: MessageValue<Data, unknown>): void
+
+- run(fn, message): void
-
-
-
-
+
-
-
Run the given function synchronously.
+Runs the given function synchronously.
Parameters
fn: ((data?: Data) => Response)
+fn: WorkerSyncFunction<Data, Response>
Function that will be executed.
---
-
-- (data?: Data): Response
--
-
-
-
Parameters
---
-
Optionaldata: DataReturns Response
value: MessageValue<Data, unknown>
+message: MessageValue<Data, unknown>
Input data for the given function.
Returns void
-Protectedrun-- run
+
+- run
-
-
-
-
+
-
-
Run the given function asynchronously.
+Runs the given function asynchronously.
Parameters
fn: ((data?: Data) => Promise<Response>)
+fn: WorkerAsyncFunction<Data, Response>
Function that will be executed.
---
-
-- (data?: Data): Promise<Response>
--
-
-
-
Parameters
---
-
Optionaldata: DataReturns Promise<Response>
value: MessageValue<Data, unknown>
+message: MessageValue<Data, unknown>
Input data for the given function.
Returns void
run
--- run
+
+- run
-
+
-
-
Call the provided function with the provided arguments in the execution context of the async resource. This will establish the context, trigger the AsyncHooks @@ -401,78 +360,77 @@ then restore the original execution context.
Since
v9.6.0
Type Parameters
-+-
-
+
This
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
+
+- (this, ...args): Result
-
-
-
+-
-
-
Parameters
this: This
this: This
Rest...args: any[]Returns Result
Rest...args: any[]Returns Result
+OptionalthisArg: ThisOptionalthisArg: ThisThe receiver to be used for the function call.
+Rest...args: any[]Rest...args: any[]Optional arguments to pass to the function.
Returns Result
-ProtectedAbstractsend-- send
+
+- send
-
-
-
-
+- Defined in src/worker/abstract-worker.ts:151
+
-
+- Defined in node_modules/.pnpm/@types+node@18.15.13/node_modules/@types/node/async_hooks.d.ts:320
+
+
-
-
-
-
-
-
-
Send a message to the main worker.
+Sends a message to the main worker.
Parameters
message: MessageValue<Response, unknown>
+message: MessageValue<Response, unknown>
The response message.
Returns void
-trigger
--- trigger
+
+- trigger
-
-
-
-
Returns
The same
-triggerAsyncIdthat is passed to theAsyncResourceconstructor.Returns number
-Staticbind-- 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
asyncResourceproperty referencing @@ -480,34 +438,35 @@ theAsyncResourceto which the function is bound.Since
v14.8.0, v12.19.0
Type Parameters
-+-
-
+
Func extends ((this: ThisArg, ...args: any[]) => any)
Func extends ((this, ...args) => any)
ThisArg
ThisArg
Parameters
fn: Func
+fn: Func
The function to bind to the current execution context.
+Optionaltype: stringOptionaltype: stringAn optional name to associate with the underlying
AsyncResource.OptionalthisArg: ThisArgReturns Func & { asyncResource: AsyncResource }
Returns Func & {
    asyncResource: AsyncResource;
}
-
+Settings
Settings
Member Visibility
Theme
+
On This Page
-- poolifier
-