Function initWorker

apps/desktop/main/worker/workerManager.ts:119–189

()

 * 初始化 Worker
 */
export function initWorker(): void {
  if (worker) {
    console.log('[WorkerManager] Worker already initialized')
    return
  }

  const workerPath = getWorkerPath()
  console.log('[WorkerManager] Initializing worker at:', workerPath)

  try {
    const initializedWorker = new Worker(workerPath, {
      workerData: {
        dbDir: getDbDir(),
        cacheDir: getCacheDir(),
        tempDir: getTempDir(),
        nlpDir: getNlpDir(),
        appVersion: getDesktopAppVersion(app.getVersion()),
      },
    })
    worker = initializedWorker

    // 监听 Worker 消息
    initializedWorker.on('message', (message) => {
      const { id, type, success, result, error, payload } = message

      const pending = pendingRequests.get(id)
      if (!pending) return

      // 处理进度消息（不删除 pending，因为还没完成）
      if (type === 'progress') {
        if (pending.onProgress) {
          pending.onProgress(payload)
        }
        return
      }

      // 处理完成或错误消息
      pendingRequests.delete(id)
      clearTimeout(pending.timeout)

      if (success) {
        pending.resolve(result)
      } else {
        pending.reject(new Error(error))
      }
    })

    // 监听 Worker 错误
    initializedWorker.on('error', (error) => {
      console.error('[WorkerManager] Worker error:', error)
    })

    // 监听 Worker 退出
    initializedWorker.on('exit', (code) => {
      console.log('[WorkerManager] Worker exited with code:', code)
      if (worker !== initializedWorker) {
        console.log('[WorkerManager] Ignoring exit from replaced worker')
        return