()
| 90 | } |
| 91 | |
| 92 | func (oq *opsQueueBase[T]) Start() { |
| 93 | oq.lock.Lock() |
| 94 | if oq.isStarted { |
| 95 | oq.lock.Unlock() |
| 96 | return |
| 97 | } |
| 98 | |
| 99 | oq.isStarted = true |
| 100 | oq.lock.Unlock() |
| 101 | |
| 102 | go oq.process() |
| 103 | } |
| 104 | |
| 105 | func (oq *opsQueueBase[T]) Stop() <-chan struct{} { |
| 106 | oq.lock.Lock() |