/** * Agent 级并发互斥锁的共享存储(32 号文档方案 B)。 * * 从 `routes/agent-chat.js` 抽出来:那边的 `POST /:agentId/chat` 路由用一个进程内 * `Map` 挡「同一个 agent 同时只允许一个活跃会话」,`company.js` 的招聘装配重试逻辑 * (`services/agent-body-filler.js`)现在也要用到同一个判据——如果两条路径各自维护 * 一份锁,各自都以为自己没有并发,实际上会同时往同一个 `SessionPool` 会话发两轮请求。 * `SessionPool.getOrCreate()`(`session-pool.js:160`)只看连接在不在,不看上一次调用有没有 * 跑完,两条路径不共享锁的话,这个坑照样在,只是换了个触发组合。 * * 纯数据结构,不含业务逻辑——acquire/release/超时判断仍然各自在调用方写,行为跟 * agent-chat.js 原来内联声明时逐字一致,这次只是换了个文件。 */ const agentChatLocks = new Map(); // agentId → { convId, startedAt } const AGENT_LOCK_TIMEOUT = 30 * 60 * 1000; // 30 分钟安全阀,与原实现一致 module.exports = { agentChatLocks, AGENT_LOCK_TIMEOUT };