X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=a61c10b2346c8a44c4094605dfe6aa25787b8f09;hb=deb85c12b77faf6974551cefcd9676e62a392086;hp=74c14ff2a33b6dc61e906e19bfdbaa7699fbc50e;hpb=280c2a7728fbeb53612d8bc115a295d0255dd991;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index 74c14ff2..a61c10b2 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -1,5 +1,5 @@ import { isMainThread, MessageChannel, SHARE_ENV, Worker } from 'worker_threads' -import type { Draft, JSONValue, MessageValue } from '../../utility-types' +import type { Draft, MessageValue } from '../../utility-types' import type { PoolOptions } from '../abstract-pool' import { AbstractPool } from '../abstract-pool' @@ -15,15 +15,15 @@ export type ThreadWorkerWithMessageChannel = Worker & Draft * * This pool selects the threads in a round robin fashion. * - * @template Data Type of data sent to the worker. - * @template Response Type of response of execution. + * @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 */ export class FixedThreadPool< - Data extends JSONValue = JSONValue, - Response extends JSONValue = JSONValue + Data = unknown, + Response = unknown > extends AbstractPool { /** * Constructs a new poolifier fixed thread pool. @@ -47,8 +47,8 @@ export class FixedThreadPool< protected async destroyWorker ( worker: ThreadWorkerWithMessageChannel ): Promise { + this.sendToWorker(worker, { kill: 1 }) await worker.terminate() - // FIXME: The tests are currently failing, so these must be changed first } protected sendToWorker ( @@ -58,18 +58,18 @@ export class FixedThreadPool< worker.postMessage(message) } - protected registerWorkerMessageListener ( - port: ThreadWorkerWithMessageChannel, - listener: (message: MessageValue) => void + protected registerWorkerMessageListener ( + messageChannel: ThreadWorkerWithMessageChannel, + listener: (message: MessageValue) => void ): void { - port.port2?.on('message', listener) + messageChannel.port2?.on('message', listener) } - protected unregisterWorkerMessageListener ( - port: ThreadWorkerWithMessageChannel, - listener: (message: MessageValue) => void + protected unregisterWorkerMessageListener ( + messageChannel: ThreadWorkerWithMessageChannel, + listener: (message: MessageValue) => void ): void { - port.port2?.removeListener('message', listener) + messageChannel.port2?.removeListener('message', listener) } protected createWorker (): ThreadWorkerWithMessageChannel {