双向依赖同步机制
// 更新任务时自动同步依赖关系 public String updateTask(int taskId, String status, List<Integer> addBlockedBy, List<Integer> addBlocks) throws IOException { Map<String, Object> task = loadTask(taskId); if (status != null) { task.put("status", status); // 任务完成时,从其他任务的 blockedBy 中移除 if ("completed".equals(status)) { clearDependency(taskId); } } if (addBlocks != null && !addBlocks.isEmpty()) { // 双向更新:更新被阻塞任务的 blockedBy 列表 for (int blockedId : distinctBlocks) { try { Map<String, Object> blockedTask = loadTask(blockedId); @SuppressWarnings("unchecked") List<Integer> blockedByList = (List<Integer>) blockedTask.get("blockedBy"); if (!blockedByList.contains(taskId)) { blockedByList.add(taskId); saveTask(blockedTask); } } catch (Exception e) { // 忽略不存在的任务 } } } // 依赖自动化:更新一个任务时,自动更新相关任务的依赖关系 // 完成清理:任务完成后自动清理对它的阻塞依赖 // 容错处理:忽略不存在的任务ID }- 关系自动维护:更新一个任务的依赖时,自动更新相关任务
- 完成时清理:任务完成后自动清理阻塞关系
- 容错设计:忽略不存在任务的引用
- 数据一致性:确保依赖关系的双向一致性
复杂查询与可视化展示
java
// 列出所有任务的摘要信息 public String listAllTasks() throws IOException { List<Map<String, Object>> tasks = new ArrayList<>(); Files.list(tasksDir) .filter(p -> p.getFileName().toString().endsWith(".json")) .sorted() // 按文件名排序,通常是ID顺序 .forEach(p -> { // 逐个加载任务文件 }); StringBuilder sb = new StringBuilder(); for (Map<String, Object> task : tasks) { String status = (String) task.get("status"); String marker = switch(status) { case "pending" -> "[ ]"; case "in_progress" -> "[>]"; case "completed" -> "[x]"; default -> "[?]"; }; int id = ((Double) task.get("id")).intValue(); String subject = (String) task.get("subject"); @SuppressWarnings("unchecked") List<Integer> blockedBy = (List<Integer>) task.get("blockedBy"); String blockedStr = (blockedBy != null && !blockedBy.isEmpty()) ? " (blocked by: " + blockedBy + ")" : ""; // 状态可视化:[ ]待办 [>]进行中 [x]已完成 // 依赖提示:显示哪些任务阻塞了当前任务 // 简洁摘要:只显示关键信息 sb.append(String.format("%s #%d: %s%s\n", marker, id, subject, blockedStr)); } return sb.toString().trim(); }- 状态可视化:用图标清晰展示任务状态
- 依赖提示:明确显示阻塞关系
- 批量加载:高效加载所有任务
- 人性化格式:便于人类阅读和理解
任务工具生态系统
java
// 完整的任务工具集定义 public enum ToolType { TASK_CREATE("task_create", "Create a new task."), // CRUD: Create TASK_GET("task_get", "Get full details of a task by ID."), // CRUD: Read TASK_UPDATE("task_update", "Update a task's status or dependencies."), // CRUD: Update TASK_LIST("task_list", "List all tasks with status summary."); // CRUD: List // 完整CRUD:创建、读取、更新、删除(通过更新状态为完成) // 语义清晰:每个工具单一职责 // 与基础工具分离:任务管理工具独立于文件操作工具 }- 完整CRUD:提供完整的任务管理操作
- 单一职责:每个工具功能明确
- 语义接口:名称明确,便于LLM理解
- 分离关注:任务工具与基础文件工具分离
JSON存储格式
java
// 任务存储格式示例 private static final Gson gson = new GsonBuilder().setPrettyPrinting().create(); private void saveTask(Map<String, Object> task) throws IOException { int id = ((Double) task.get("id")).intValue(); Path path = tasksDir.resolve("task_" + id + ".json"); Files.writeString(path, gson.toJson(task)); // 美化的JSON格式 } // 标准化格式:每个任务存储为格式化的JSON文件 // 命名规范:task_<id>.json // 人类可读:美化的JSON便于手动查看和编辑 // 可互操作:标准JSON格式支持外部工具处理- 标准化存储:JSON是通用的数据交换格式
- 可读性:美化格式便于调试
- 可扩展:随时可以添加新字段
- 互操作性:其他工具可以读取任务文件
架构演进与价值
从 AgentWithTodo 到 TaskSystem 的升级:
| 维度 | AgentWithTodo | TaskSystem |
|---|---|---|
| 存储方式 | 内存存储 | 文件系统持久化 |
| 依赖管理 | 无依赖关系 | 双向依赖管理 |
| 数据持久性 | 重启丢失 | 永久保存 |
| 任务复杂性 | 简单待办 | 复杂项目管理 |
| 协同能力 | 单人使用 | 支持团队协 |
