IsCanceled 检查是否已取消
(taskID string)
| 119 | |
| 120 | // IsCanceled 检查是否已取消 |
| 121 | func (s *InMemoryTaskStore) IsCanceled(taskID string) bool { |
| 122 | s.mu.RLock() |
| 123 | defer s.mu.RUnlock() |
| 124 | |
| 125 | return s.activeCancellations[taskID] |
| 126 | } |
| 127 | |
| 128 | // makeKey 生成存储键 |
| 129 | func makeKey(agentID, taskID string) string { |
no outgoing calls