- protected async destroyWorker (worker: Worker): Promise<void> {
- this.sendToWorker(worker, { kill: 1 })
- await worker.terminate()
+ protected sendToWorker (
+ workerNodeKey: number,
+ message: MessageValue<Data>,
+ transferList?: TransferListItem[]
+ ): void {
+ this.workerNodes[workerNodeKey].messageChannel?.port1?.postMessage(
+ { ...message, workerId: this.getWorkerInfo(workerNodeKey).id },
+ transferList
+ )