Co-authored-by: Icaro Motta <icaro.ldm@gmail.com>
This commit is contained in:
parent
5bb7c6a8f3
commit
dd787c982a
|
@ -193,9 +193,9 @@ func (s *Scheduler) Stop() {
|
|||
for pair := s.queue.Oldest(); pair != nil; pair = pair.Next() {
|
||||
// Notify the queued one that they are canceled
|
||||
if pair.Value.policy == ReplacementPolicyCancelOld {
|
||||
go func() {
|
||||
pair.Value.resFn(nil, pair.Value.taskType, context.Canceled)
|
||||
}()
|
||||
go func(val *taskContext) {
|
||||
val.resFn(nil, val.taskType, context.Canceled)
|
||||
}(pair.Value)
|
||||
}
|
||||
s.queue.Delete(pair.Value.taskType)
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue