Method assignWorkToThread

server/utils/import-queue.ts:281–302

(workerId: number)

  }

  private async assignWorkToThread(workerId: number): Promise<void> {
    const workItem = await this.getNextWorkItem(workerId);

    const worker = this.workerThreads.get(workerId);
    if (!worker) return;

    if (workItem.job) {
      worker.postMessage({
        type: "processJob",
        data: workItem.job,
      });
    } else if (workItem.chunk) {
      worker.postMessage({
        type: "processChunk",
        data: workItem.chunk,
      });
    } else {
      setTimeout(() => {
        worker.postMessage({ type: "requestWork" });
      }, 1000);
    }
  }

  private handleWorkCompletion(workerId: number, data: any): void {
    this.cleanupWorkerAssignment(workerId);