Save 保存任务
(agentID string, task *Task)
| 63 | |
| 64 | // Save 保存任务 |
| 65 | func (s *InMemoryTaskStore) Save(agentID string, task *Task) error { |
| 66 | s.mu.Lock() |
| 67 | defer s.mu.Unlock() |
| 68 | |
| 69 | key := makeKey(agentID, task.ID) |
| 70 | // 存储副本,防止内部修改 |
| 71 | s.tasks[key] = copyTask(task) |
| 72 | |
| 73 | return nil |
| 74 | } |
| 75 | |
| 76 | // Delete 删除任务 |
| 77 | func (s *InMemoryTaskStore) Delete(agentID, taskID string) error { |