Skip to content

Commit e7923c4

Browse files
zeripathlafriks
authored andcommitted
Fix missing unlock in uniquequeue (#9790)
1 parent 9343d2f commit e7923c4

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

modules/sync/unique_queue.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -82,6 +82,7 @@ func (q *UniqueQueue) AddFunc(id interface{}, fn func()) {
8282
idStr := com.ToStr(id)
8383
q.table.lock.Lock()
8484
if _, ok := q.table.pool[idStr]; ok {
85+
q.table.lock.Unlock()
8586
return
8687
}
8788
q.table.pool[idStr] = struct{}{}

0 commit comments

Comments
 (0)