zeripath
pirms 4 gadiem
1 mainītis faili ar 1 papildinājumiem un 0 dzēšanām
+ 1
- 0
modules/sync/unique_queue.go
Parādīt failu
| idStr := com.ToStr(id) | idStr := com.ToStr(id) | ||||
| q.table.lock.Lock() | q.table.lock.Lock() | ||||
| if _, ok := q.table.pool[idStr]; ok { | if _, ok := q.table.pool[idStr]; ok { | ||||
| q.table.lock.Unlock() | |||||
| return | return | ||||
| } | } | ||||
| q.table.pool[idStr] = struct{}{} | q.table.pool[idStr] = struct{}{} |
Notiek ielāde…