X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fthread%2Ffixed.ts;h=570c9c8b7f3ed718aaf2309b41e8b8486477d423;hb=65d7a1c9177d558c01570f4013b7aa23bbee952d;hp=764d5851d9be4d6cd9c52b2333b1348c50c803bf;hpb=14a2e530e555fa52f98454e182d0094e0ff5d86f;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index 764d5851..570c9c8b 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -1,8 +1,8 @@ import { - isMainThread, MessageChannel, SHARE_ENV, - Worker + Worker, + isMainThread } from 'node:worker_threads' import type { Draft, MessageValue } from '../../utility-types' import { AbstractPool } from '../abstract-pool' @@ -22,7 +22,7 @@ export type ThreadWorkerWithMessageChannel = Worker & Draft * This pool selects the threads in a round robin fashion. * * @typeParam Data - Type of data sent to the worker. This can only be serializable data. - * @typeParam Response - Type of response of execution. This can only be serializable data. + * @typeParam Response - Type of execution response. This can only be serializable data. * @author [Alessandro Pio Ardizio](https://github.com/pioardi) * @since 0.0.1 */ @@ -68,10 +68,10 @@ export class FixedThreadPool< /** @inheritDoc */ protected registerWorkerMessageListener( - messageChannel: ThreadWorkerWithMessageChannel, + worker: ThreadWorkerWithMessageChannel, listener: (message: MessageValue) => void ): void { - messageChannel.port2?.on('message', listener) + worker.port2?.on('message', listener) } /** @inheritDoc */