/**
 * 迷你 React 調(diào)度器
 * 實(shí)現(xiàn)：多優(yōu)先級(jí)隊(duì)列 + 時(shí)間切片 + 任務(wù)調(diào)度
 * 對(duì)標(biāo) React Concurrent Mode 核心邏輯
 * 可用于 Vue / React 模擬低優(yōu)先級(jí)更新、AI流式打字機(jī)優(yōu)化
 */
export function useMiniReactScheduler() {
  // 優(yōu)先級(jí)定義（與 React 保持對(duì)齊，數(shù)值越小優(yōu)先級(jí)越高）
  const Priority = {
    IMMEDIATE: 0,      // 同步緊急任務(wù)
    USER_BLOCKING: 1,  // 用戶阻塞型任務(wù)：輸入、點(diǎn)擊、拖拽
    NORMAL: 2,         // 普通更新：列表渲染、數(shù)據(jù)展示
    LOW: 3,            // 低優(yōu)先級(jí)：AI打字、日志、埋點(diǎn)
    IDLE: 4            // 空閑任務(wù)：requestIdleCallback 類似語(yǔ)義
  }

  // 多優(yōu)先級(jí)任務(wù)隊(duì)列（React 核心設(shè)計(jì)）
  const taskQueues = {
    [Priority.IMMEDIATE]: [],
    [Priority.USER_BLOCKING]: [],
    [Priority.NORMAL]: [],
    [Priority.LOW]: [],
    [Priority.IDLE]: []
  }

  let isScheduling = false
  const sliceTime = 8 // 時(shí)間切片默認(rèn)8ms，與React一致
  const channel = new MessageChannel()
  const { port1, port2 } = channel

  // 調(diào)度執(zhí)行：按優(yōu)先級(jí)從高到低消費(fèi)任務(wù)
  port2.onmessage = () => {
    const startTime = performance.now()

    // 遍歷所有優(yōu)先級(jí)隊(duì)列，高優(yōu)先級(jí)先執(zhí)行
    for (const p of [0, 1, 2, 3, 4]) {
      const queue = taskQueues[p]
      while (queue.length > 0) {
        const { task } = queue.shift()
        try {
          task() // 執(zhí)行任務(wù)
        } catch (err) {
          console.error('調(diào)度任務(wù)執(zhí)行異常：', err)
        }

        // 時(shí)間切片耗盡，主動(dòng)讓出主線程
        if (performance.now() - startTime > sliceTime) {
          isScheduling = false
          schedule() // 剩余任務(wù)下一幀繼續(xù)
          return
        }
      }
    }

    isScheduling = false
  }

  // 觸發(fā)調(diào)度
  function schedule() {
    if (!isScheduling) {
      isScheduling = true
      port1.postMessage('') // 宏任務(wù)推入隊(duì)列
    }
  }

  /**
   * 添加任務(wù)到調(diào)度器
   * @param {Function} task 任務(wù)函數(shù)
   * @param {number} priority 優(yōu)先級(jí)
   */
  function addTask(task, priority = Priority.NORMAL) {
    if (typeof task !== 'function') return
    taskQueues[priority].push({ task })
    schedule()
  }

  // 清空所有任務(wù)（組件卸載時(shí)調(diào)用，防止內(nèi)存泄漏）
  function clearAllTasks() {
    Object.values(taskQueues).forEach(queue => queue.length = 0)
  }

  return {
    addTask,
    clearAllTasks,
    Priority
  }
}

// 初始化調(diào)度器
const { addTask, Priority } = useMiniReactScheduler()

// AI 流式文字更新 → 低優(yōu)先級(jí)
function updateAIContent(text) {
  addTask(() => {
    // Vue / React 視圖更新
    aiMessage.value = text
  }, Priority.LOW)
}

// 用戶輸入框 → 高優(yōu)先級(jí)
function handleUserInput(e) {
  addTask(() => {
    userInput.value = e.target.value
  }, Priority.USER_BLOCKING)
}

// 組件卸載清空任務(wù)
onUnmounted(() => {
  clearAllTasks()
})