X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2Fthread-worker.ts;h=7a766a958ccbb41c9b29bbe76c04890eec61604d;hb=f59e102739e13698f278f1d9d58ab26ed8150442;hp=a8424fbf0151e0ffa59674b4a5575fe604b5543e;hpb=ed6dd37f9e137cf659523d9d792f0171eedcb8ed;p=poolifier.git diff --git a/src/worker/thread-worker.ts b/src/worker/thread-worker.ts index a8424fbf..7a766a95 100644 --- a/src/worker/thread-worker.ts +++ b/src/worker/thread-worker.ts @@ -1,8 +1,13 @@ -import type { MessagePort } from 'worker_threads' -import { isMainThread, parentPort } from 'worker_threads' +import { + type MessagePort, + isMainThread, + parentPort, + threadId +} from 'node:worker_threads' import type { MessageValue } from '../utility-types' import { AbstractWorker } from './abstract-worker' import type { WorkerOptions } from './worker-options' +import type { TaskFunctions, WorkerFunction } from './worker-functions' /** * A thread worker used by a poolifier `ThreadPool`. @@ -13,8 +18,8 @@ import type { WorkerOptions } from './worker-options' * If you use a `DynamicThreadPool` the extra workers that were created will be terminated, * but the minimum number of workers will be guaranteed. * - * @typeParam Data - Type of data this worker receives from pool's execution. This can only be serializable data. - * @typeParam Response - Type of response the worker sends back to the main thread. This can only be serializable data. + * @typeParam Data - Type of data this worker receives from pool's execution. This can only be structured-cloneable data. + * @typeParam Response - Type of response the worker sends back to the main thread. This can only be structured-cloneable data. * @author [Alessandro Pio Ardizio](https://github.com/pioardi) * @since 0.0.1 */ @@ -25,15 +30,34 @@ export class ThreadWorker< /** * Constructs a new poolifier thread worker. * - * @param fn - Function processed by the worker when the pool's `execution` function is invoked. + * @param taskFunctions - Task function(s) processed by the worker when the pool's `execution` function is invoked. * @param opts - Options for the worker. */ - public constructor (fn: (data: Data) => Response, opts: WorkerOptions = {}) { - super('worker-thread-pool:poolifier', isMainThread, fn, parentPort, opts) + public constructor ( + taskFunctions: + | WorkerFunction + | TaskFunctions, + opts: WorkerOptions = {} + ) { + super( + 'worker-thread-pool:poolifier', + isMainThread, + taskFunctions, + parentPort as MessagePort, + opts + ) + if (!this.isMain) { + this.sendToMainWorker({ workerId: this.id, started: true }) + } } - /** {@inheritDoc} */ + protected get id (): number { + return threadId + } + + /** @inheritDoc */ protected sendToMainWorker (message: MessageValue): void { + console.log('sending message to main worker(thread)', message) this.getMainWorker().postMessage(message) } }