Releases: enriquebris/goconcurrentqueue
Releases · enriquebris/goconcurrentqueue
Prevents FIFO.DequeueOrWaitForNextElement to keep waiting for a waitChan while internal queue contains items
Prevents FIFO.DequeueOrWaitForNextElement to keep waiting for a waitChan while internal queue contains items
Latest
- Prevents FIFO.DequeueOrWaitForNextElement to keep waiting for a waitChan while internal queue contains items
Prevents FIFO.DequeueOrWaitForNextElement to add useless wait channels
- Prevents FIFO.DequeueOrWaitForNextElement to add useless wait channels
Prevents FIFO.DequeueOrWaitForNextElement to gets blocked
Prevents FIFO.DequeueOrWaitForNextElement to gets blocked when waiting for an enqueued element.
Unblocking FixedFifo.Enqueue
FixedFifo.Enqueue prevents to gets blocked trying to send the item over an invalid waitForNextElementChan channel
DequeueOrWaitForNextElementContext
- Added DequeueOrWaitForNextElementContext(...) both for FIFO and FixedFIFO
- Updated tests:
FixedFIFO.TestDequeueOrWaitForNextElementMultiGR
FixedFIFO.TestDequeueOrWaitForNextElementWithEmptyQueue
DequeueOrWaitForNextElement
Added DequeueOrWaitForNextElement() both for FIFO and FixedFIFO
FIFO queue
First In First Out (FIFO) concurrent queue