X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Futility-types.ts;h=be0ed287633b24e211e46024f736aefc033701e3;hb=09d618c908c36b2d9da0f034900510fa4e6ea8d6;hp=0723b4395407a94b18d3cafcfc6e5db2360017e0;hpb=b0a4db63f53f4df5d60abc592f32043468626574;p=poolifier.git diff --git a/src/utility-types.ts b/src/utility-types.ts index 0723b439..be0ed287 100644 --- a/src/utility-types.ts +++ b/src/utility-types.ts @@ -1,6 +1,6 @@ import type { EventLoopUtilization } from 'node:perf_hooks' +import type { MessagePort } from 'node:worker_threads' import type { KillBehavior } from './worker/worker-options' -import type { IWorker } from './pools/worker' /** * Task error. @@ -118,19 +118,19 @@ export interface MessageValue * Whether the worker starts or stops its activity check. */ readonly checkActive?: boolean + /** + * Message port. + */ + readonly port?: MessagePort } /** - * An object holding the execution response promise resolve/reject callbacks. + * An object holding the task execution response promise resolve/reject callbacks. * - * @typeParam Worker - Type of worker. * @typeParam Response - Type of execution response. This can only be structured-cloneable data. * @internal */ -export interface PromiseResponseWrapper< - Worker extends IWorker, - Response = unknown -> { +export interface PromiseResponseWrapper { /** * Resolve callback to fulfill the promise. */ @@ -140,7 +140,7 @@ export interface PromiseResponseWrapper< */ readonly reject: (reason?: unknown) => void /** - * The worker handling the execution. + * The worker node key executing the task. */ - readonly worker: Worker + readonly workerNodeKey: number }