ProjectHentai/alist
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: cancel task while wait for worker

Browse Source
This commit is contained in:
Noah Hsu 2022-06-29 22:06:56 +08:00
parent fd55f2cbfa
commit e614faa99b
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/task/manager.go
View File

@ -32,6 +32,9 @@ func (tm *Manager[K]) do(task *Task[K]) {
log.Debugf("task [%s] starting", task.Name) log.Debugf("task [%s] starting", task.Name)
task.run() task.run()
log.Debugf("task [%s] ended", task.Name) log.Debugf("task [%s] ended", task.Name)
case <-task.Ctx.Done():
log.Debugf("task [%s] canceled", task.Name)
return
} }
// return worker // return worker
tm.workerC <- struct{}{} tm.workerC <- struct{}{}