Function sendToWorkerWithProgress

apps/desktop/main/worker/workerManager.ts:233–263

* 发送消息到 Worker 并等待响应（带进度回调） * 用于流式导入等长时间操作

(
  type: string,
  payload: any,
  onProgress?: (progress: ParseProgress) => void,
  timeoutMs: number = 600000 // 默认 10 分钟超时
)

 * 用于流式导入等长时间操作
 */
function sendToWorkerWithProgress<T>(
  type: string,
  payload: any,
  onProgress?: (progress: ParseProgress) => void,
  timeoutMs: number = 600000 // 默认 10 分钟超时
): Promise<T> {
  return new Promise((resolve, reject) => {
    if (!worker) {
      try {
        initWorker()
      } catch (error) {
        reject(new Error('Worker not initialized'))
        return
      }
    }

    const requestWorker = worker!
    const id = `req_${++requestIdCounter}`

    const timeout = setTimeout(() => {
      if (pendingRequests.has(id)) {
        pendingRequests.delete(id)
        reject(new Error(`Worker request timeout: ${type}`))
      }
    }, timeoutMs)

    pendingRequests.set(id, { resolve, reject, timeout, restartOnTimeout: false, onProgress })

    requestWorker.postMessage({ id, type, payload })
  })
}

/**
 * 关闭 Worker（同步版本，用于一般场景）