AddCancellation 添加取消信号
(taskID string)
| 103 | |
| 104 | // AddCancellation 添加取消信号 |
| 105 | func (s *InMemoryTaskStore) AddCancellation(taskID string) { |
| 106 | s.mu.Lock() |
| 107 | defer s.mu.Unlock() |
| 108 | |
| 109 | s.activeCancellations[taskID] = true |
| 110 | } |
| 111 | |
| 112 | // RemoveCancellation 移除取消信号 |
| 113 | func (s *InMemoryTaskStore) RemoveCancellation(taskID string) { |
no outgoing calls