async function* agentLoop(query: Query): AsyncGenerator<Message> {
  // 1. 流式输出：模型边输出边流式返回
  for await (const token of model.stream(query)) {
    yield { type: 'token', value: token };
  }

  // 2. 工具执行：流式过程中预启动只读工具
  const speculativeReads = await executeReadToolsSpeculatively(query);

  // 3. 错误恢复：自动重试与上下文压缩
  if (error) {
    await recoverAndCompact();
  }

  // 4. 上下文压缩：4层压缩机制
  await compressContextIfNeeded();
}

// 模型还在输出thinking，工具已经开始执行
async function speculativeExecute(query: Query) {
  const plan = await model.plan(query); // 首次token到达即规划

  // 只读工具可以立即执行
  const readResults = await Promise.all(
    plan.readTools.map(tool => tool.execute())
  );

  // 写工具等待模型确认
  if (plan.writeTools.length > 0) {
    await model.confirm(); // 等待完整响应
    await executeWrites(plan.writeTools);
  }

  return { readResults, writeResults };
}

// 按安全分类分区
const partitions = {
  read: tools.filter(t => t.safety === 'read'),
  write: tools.filter(t => t.safety === 'write'),
  dangerous: tools.filter(t => t.safety === 'dangerous')
};

// 只读工具完全并行
const readResults = await Promise.all(
  partitions.read.map(t => t.execute())
);

// 写工具串行执行
for (const tool of partitions.write) {
  await tool.execute();
}

// 主Agent的Prompt结构
const mainPrompt = [
  systemPrompt,      // 系统级前缀（不变）
  projectContext,    // 项目上下文（不变）
  taskHistory,       // 任务历史（不变）
  // ↑ 这三部分 = 可缓存前缀 ↑

  currentTask        // 当前任务（每次不同）
];

// Fork Agent继承相同前缀
const forkedPrompt = [
  systemPrompt,      // 共享，0额外Token
  projectContext,    // 共享，0额外Token
  taskHistory,       // 共享，0额外Token

  forkedTask         // Fork特有任务
];

// 结果：~95%输入Token节省

// 传统嵌入搜索
const results = await embeddingSearch(query, memories);

// Claude Code的LLM召回
async function recallMemories(query: Query, context: Context) {
  // 用Sonnet做side-query
  const relevantMemories = await sonnet.query(
    `Given the current task: ${query}
     And context: ${context}
     Which memories from past sessions are relevant?
     List them verbatim.`
  );

  return relevantMemories;
}

// 并行I/O最大化
async function bootstrap() {
  const [
    config,      // 配置加载
    skills,      // 技能加载
    model,       // 模型初始化
    memory,      // 内存恢复
    ui           // UI初始化
  ] = await Promise.all([
    loadConfig(),
    loadSkills(),
    initModel(),
    restoreMemory(),
    initUI()
  ]);

  return { config, skills, model, memory, ui };
  // 总耗时 = max(各阶段) 而非 sum(各阶段)
}

// 默认8K输出上限
const OUTPUT_SLOT = 8 * 1024;

// 当输出命中上限时，自动扩展到64K
async function handleOutputOverflow(output: string) {
  if (output.length >= OUTPUT_SLOT) {
    await escalateOutputSlot(64 * 1024);
    // 节省策略：在99%的请求中，8K足够
  }
}

// 预计算的Bitmap索引
const fileIndex = {
  content: new Bitmap(),  // 内容位图
  path: new Bitmap(),      // 路径位图
  symbol: new Bitmap()     // 符号位图
};

// 先用Bitmap过滤候选文件
const candidates = fileIndex.content.and(queryBitmap);

// 阶段1：启动时只加载元数据
const skillMeta = {
  name: 'git操作',
  triggers: ['git commit', 'git push'],
  permissions: ['read:repo', 'write:repo'],
  // 完整内容不加载
};

// 阶段2：触发时才加载完整内容
async function invokeSkill(skill: SkillMeta) {
  if (!skill.isLoaded) {
    skill.content = await loadSkillContent(skill.path);
    skill.isLoaded = true;
  }
  return execute(skill.content);
}

// 启动时冻结所有配置
const frozenConfig = deepFreeze(loadConfig());

// 运行时无法修改，防止注入攻击
function preventInjection(attemptedChange: any) {
  // 任何尝试修改冻结配置的都会被拒绝
  throw new SecurityError('Config is immutable after startup');
}

const permissionMatrix = {
  // 默认拒绝
  default: 'deny',

  // 明确允许
  allow: [
    'Read:repo',      // 读取代码库
    'Write:repo',    // 修改代码
    'Execute:shell',  // 执行Shell命令
  ],

  // 明确拒绝
  deny: [
    'Execute:sudo',   // 禁止提权
    'Read:/etc/*',   // 禁止读取系统配置
    'Write:~/.ssh',  // 禁止修改SSH配置
  ]
};