Wait stops until all the workers stopped.
()
| 78 | |
| 79 | // Wait stops until all the workers stopped. |
| 80 | func (wq *WorkQueue) Wait() { |
| 81 | wq.done.Wait() |
| 82 | } |
| 83 | |
| 84 | // WaitDone stops until all jobs on the queue have been processed. |
| 85 | func (wq *WorkQueue) WaitDone() { |