X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=a8161f6783f764831ef632bc4d48205419ab1850;hb=d25a8ffcc8447163ac52832bd9a4f8819983f819;hp=3212678f8635bc3dc3a67ed6500e5ab38ee38b66;hpb=a76fac14098cf2138cf8d6997ac7c89d8c3ae508;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index 3212678f..a8161f67 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -16,8 +16,8 @@ export type ThreadWorkerWithMessageChannel = Worker & Draft * * This pool selects the threads in a round robin fashion. * - * @template DataType of data sent to the worker. This can only be serializable data. - * @template ResponseType of response of execution. This can only be serializable data. + * @template Data Type of data sent to the worker. This can only be serializable data. + * @template Response Type of response of execution. This can only be serializable data. * @author [Alessandro Pio Ardizio](https://github.com/pioardi) * @since 0.0.1 */ @@ -30,7 +30,7 @@ export class FixedThreadPool< * * @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 opts Options for this fixed thread pool. */ public constructor ( numberOfThreads: number, @@ -62,7 +62,7 @@ export class FixedThreadPool< } /** @inheritDoc */ - public registerWorkerMessageListener ( + public registerWorkerMessageListener( messageChannel: ThreadWorkerWithMessageChannel, listener: (message: MessageValue) => void ): void { @@ -82,7 +82,7 @@ export class FixedThreadPool< worker.postMessage({ parent: port1 }, [port1]) worker.port1 = port1 worker.port2 = port2 - // Listen worker messages. + // Listen to worker messages. this.registerWorkerMessageListener(worker, super.workerListener()) }