Function sendToWorker

apps/desktop/main/worker/workerManager.ts:194–227

* 发送消息到 Worker 并等待响应

(type: string, payload: any, options: number | WorkerRequestOptions = {})

 * 发送消息到 Worker 并等待响应
 */
function sendToWorker<T>(type: string, payload: any, options: number | WorkerRequestOptions = {}): Promise<T> {
  return new Promise((resolve, reject) => {
    if (!worker) {
      try {
        initWorker()
      } catch (error) {
        reject(new Error('Worker not initialized'))
        return
      }
    }

    const timeoutMs = typeof options === 'number' ? options : (options.timeoutMs ?? 60000)
    const restartOnTimeout =
      typeof options === 'number'
        ? isRestartableReadOnlyRequestType(type)
        : (options.restartOnTimeout ?? isRestartableReadOnlyRequestType(type))
    const requestWorker = worker!
    const id = `req_${++requestIdCounter}`

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

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

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

/**
 * 发送消息到 Worker 并等待响应（带进度回调）