FileTaskManager 基于文件系统的任务管理器实现
| 70 | |
| 71 | // FileTaskManager 基于文件系统的任务管理器实现 |
| 72 | type FileTaskManager struct { |
| 73 | mu sync.RWMutex |
| 74 | tasks map[string]*TaskInfo |
| 75 | dataDir string |
| 76 | outputDir string |
| 77 | cleanupChan chan string |
| 78 | } |
| 79 | |
| 80 | // NewFileTaskManager 创建基于文件的任务管理器 |
| 81 | func NewFileTaskManager() *FileTaskManager { |
nothing calls this directly
no outgoing calls
no test coverage detected