Skip to content

Commit 7083d60

Browse files
fix: deadlock
1 parent b4a51f7 commit 7083d60

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

decrypt.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -194,8 +194,7 @@ func (s *Scheduler) requeueTask(task *Task) {
194194
s.queueLock.Lock()
195195
s.taskQueue.PushFront(task)
196196
s.queueLock.Unlock()
197-
// 注意:这里不再 Signal,因为调用 requeueTask 的地方
198-
// (通常是 process 循环) 会自己决定下一步动作
197+
s.queueCond.Signal()
199198
}
200199

201200
func (s *Scheduler) Shutdown() {

0 commit comments

Comments
 (0)