X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fworker-node.ts;h=ea50ebdbe036353070af773d4470213c10061237;hb=21f710aa73abbb5d90328cfb199adfc0f7a70406;hp=eb2085bca21eeac3b7f225475c71d15abb75a28f;hpb=bf4ef2cab6fb0dc722f5b5b9deed78c3e27258db;p=poolifier.git diff --git a/src/pools/worker-node.ts b/src/pools/worker-node.ts index eb2085bc..ea50ebdb 100644 --- a/src/pools/worker-node.ts +++ b/src/pools/worker-node.ts @@ -10,6 +10,12 @@ import { type WorkerUsage } from './worker' +/** + * Worker node. + * + * @typeParam Worker - Type of worker. + * @typeParam Data - Type of data sent to the worker. This can only be structured-cloneable data. + */ export class WorkerNode implements IWorkerNode { public readonly worker: Worker @@ -17,6 +23,13 @@ implements IWorkerNode { public usage: WorkerUsage private readonly tasksQueue: Queue> + /** + * Constructs a new worker node. + * + * @param worker - The worker. + * @param workerType - The worker type. + * @internal + */ constructor (worker: Worker, workerType: WorkerType) { this.worker = worker this.info = this.initWorkerInfo(worker, workerType) @@ -62,7 +75,7 @@ implements IWorkerNode { id: this.getWorkerId(worker, workerType), type: workerType, dynamic: false, - started: true + ready: false } } @@ -106,6 +119,7 @@ implements IWorkerNode { * Gets the worker id. * * @param worker - The worker. + * @param workerType - The worker type. * @returns The worker id. */ private getWorkerId (