reduce working count
(count int64)
| 40 | |
| 41 | // reduce working count |
| 42 | func (q *Queue) Finish(count int64) { |
| 43 | q.mux.Lock() |
| 44 | defer q.mux.Unlock() |
| 45 | |
| 46 | q.working -= count |
| 47 | } |
| 48 | |
| 49 | // Push add a node to queue |
| 50 | func (q *Queue) Push(node QueueNode) { |