X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=85c5c9be8f94f4dc1b41ea873d0bbd9e742dac19;hb=3a5027122ca6401ae1d755843b20f714c61e3240;hp=78912c2b03d11537bebce5cc0576d058157321af;hpb=ded253e27e59ae936fe91d789d8454b7eb11dd6a;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index 78912c2b..85c5c9be 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -1,7 +1,7 @@ import { isMainThread, type TransferListItem, - type Worker + type Worker, } from 'node:worker_threads' import type { MessageValue } from '../../utility-types.js' @@ -16,7 +16,6 @@ export type ThreadPoolOptions = PoolOptions /** * A thread pool with a fixed number of threads. - * * @typeParam Data - Type of data sent to the worker. This can only be structured-cloneable data. * @typeParam Response - Type of execution response. This can only be structured-cloneable data. * @author [Alessandro Pio Ardizio](https://github.com/pioardi) @@ -28,10 +27,10 @@ export class FixedThreadPool< > extends AbstractPool { /** * Constructs a new poolifier fixed thread pool. - * * @param numberOfThreads - Number of threads for this pool. * @param filePath - Path to an implementation of a `ThreadWorker` file, which can be relative or absolute. * @param opts - Options for this fixed thread pool. + * @param maximumNumberOfThreads */ public constructor ( numberOfThreads: number, @@ -51,12 +50,12 @@ export class FixedThreadPool< protected sendToWorker ( workerNodeKey: number, message: MessageValue, - transferList?: TransferListItem[] + transferList?: readonly TransferListItem[] ): void { this.workerNodes[workerNodeKey]?.messageChannel?.port1.postMessage( { ...message, - workerId: this.getWorkerInfo(workerNodeKey)?.id + workerId: this.getWorkerInfo(workerNodeKey)?.id, } satisfies MessageValue, transferList ) @@ -71,7 +70,7 @@ export class FixedThreadPool< { ready: false, workerId: this.getWorkerInfo(workerNodeKey)?.id, - port: port2 + port: port2, } satisfies MessageValue, [port2] )