Method createWorkerThread

server/utils/import-queue.ts:226–248

(workerId: number)

  }

  private createWorkerThread(workerId: number): void {
    const worker = new Worker(__filename, {
      workerData: { workerId, isWorkerThread: true },
    });

    worker.on("message", (message) => {
      this.handleWorkerMessage(workerId, message);
    });

    worker.on("error", (error) => {
      handleLog(`Worker thread ${workerId} error: ${(error as Error).message}`);
      this.restartWorkerThread(workerId);
    });

    worker.on("exit", (code) => {
      if (code !== 0) {
        handleLog(`Worker thread ${workerId} exited with code ${code}`);
        this.restartWorkerThread(workerId);
      }
    });

    this.workerThreads.set(workerId, worker);
  }

  private restartWorkerThread(workerId: number): void {
    const oldWorker = this.workerThreads.get(workerId);