Stop stops all worker after all job get done
()
| 103 | |
| 104 | //Stop stops all worker after all job get done |
| 105 | func (queue *Queue) Stop() { |
| 106 | queue.waitGroup.Wait() |
| 107 | queue.ForceStop() |
| 108 | } |
| 109 | |
| 110 | //ForceStop forces job manager without waiting job complete |
| 111 | func (queue *Queue) ForceStop() { |