Close stops the queue runner and releases queue assets
()
| 122 | |
| 123 | // Close stops the queue runner and releases queue assets |
| 124 | func (q *Queue) Close() { |
| 125 | q.stopC <- true |
| 126 | time.Sleep(time.Millisecond) |
| 127 | for !q.IsStopped() { |
| 128 | time.Sleep(time.Second) |
| 129 | } |
| 130 | } |
| 131 | |
| 132 | // IsStopped checks if the queue is still running and active |
| 133 | func (q *Queue) IsStopped() bool { |