InMemoryTaskStore 内存任务存储 使用 Map 存储,支持并发访问
| 33 | // InMemoryTaskStore 内存任务存储 |
| 34 | // 使用 Map 存储,支持并发访问 |
| 35 | type InMemoryTaskStore struct { |
| 36 | mu sync.RWMutex |
| 37 | tasks map[string]*Task // key: "agentID-taskID" |
| 38 | activeCancellations map[string]bool // key: taskID |
| 39 | } |
| 40 | |
| 41 | // NewInMemoryTaskStore 创建内存任务存储 |
| 42 | func NewInMemoryTaskStore() *InMemoryTaskStore { |
nothing calls this directly
no outgoing calls
no test coverage detected