X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=d22d75fb3b5a397e8a2371a700d53d4f243160ba;hb=19b53d08bec0e752fb3bdf054a0810db8bb8565d;hp=088d72c920092cb8637b5f86edbdedf62432f672;hpb=9d9fb7b64a28d150583fe1bcd895893f6736d9d4;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index 088d72c9..d22d75fb 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -1,14 +1,12 @@ import { - type MessageChannel, - type MessagePort, type TransferListItem, type Worker, isMainThread } from 'node:worker_threads' -import type { MessageValue } from '../../utility-types' -import { AbstractPool } from '../abstract-pool' -import { type PoolOptions, type PoolType, PoolTypes } from '../pool' -import { type WorkerType, WorkerTypes } from '../worker' +import type { MessageValue } from '../../utility-types.js' +import { AbstractPool } from '../abstract-pool.js' +import { type PoolOptions, type PoolType, PoolTypes } from '../pool.js' +import { type WorkerType, WorkerTypes } from '../worker.js' /** * Options for a poolifier thread pool. @@ -54,8 +52,11 @@ export class FixedThreadPool< message: MessageValue, transferList?: TransferListItem[] ): void { - this.workerNodes[workerNodeKey].messageChannel?.port1?.postMessage( - { ...message, workerId: this.getWorkerInfo(workerNodeKey).id }, + this.workerNodes[workerNodeKey].messageChannel?.port1.postMessage( + { + ...message, + workerId: this.getWorkerInfo(workerNodeKey)?.id + } satisfies MessageValue, transferList ) } @@ -63,14 +64,14 @@ export class FixedThreadPool< /** @inheritDoc */ protected sendStartupMessageToWorker (workerNodeKey: number): void { const workerNode = this.workerNodes[workerNodeKey] - const port2: MessagePort = (workerNode.messageChannel as MessageChannel) - .port2 + // eslint-disable-next-line @typescript-eslint/no-non-null-assertion + const port2 = workerNode.messageChannel!.port2 workerNode.worker.postMessage( { ready: false, - workerId: this.getWorkerInfo(workerNodeKey).id, + workerId: this.getWorkerInfo(workerNodeKey)?.id, port: port2 - }, + } satisfies MessageValue, [port2] ) } @@ -80,7 +81,7 @@ export class FixedThreadPool< workerNodeKey: number, listener: (message: MessageValue) => void ): void { - this.workerNodes[workerNodeKey].messageChannel?.port1?.on( + this.workerNodes[workerNodeKey].messageChannel?.port1.on( 'message', listener ) @@ -91,7 +92,7 @@ export class FixedThreadPool< workerNodeKey: number, listener: (message: MessageValue) => void ): void { - this.workerNodes[workerNodeKey].messageChannel?.port1?.once( + this.workerNodes[workerNodeKey].messageChannel?.port1.once( 'message', listener ) @@ -102,7 +103,7 @@ export class FixedThreadPool< workerNodeKey: number, listener: (message: MessageValue) => void ): void { - this.workerNodes[workerNodeKey].messageChannel?.port1?.off( + this.workerNodes[workerNodeKey].messageChannel?.port1.off( 'message', listener ) @@ -113,6 +114,11 @@ export class FixedThreadPool< return false } + /** @inheritDoc */ + protected checkAndEmitDynamicWorkerCreationEvents (): void { + /* noop */ + } + /** @inheritDoc */ protected get type (): PoolType { return PoolTypes.fixed