Skip to content

Commit dbe6136

Browse files
zeripathsapk
authored andcommitted
Fix missing unlock in uniquequeue (#9791)
1 parent 6d1f7e9 commit dbe6136

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)