Skip to content

Releases: enriquebris/goconcurrentqueue

Prevents FIFO.DequeueOrWaitForNextElement to keep waiting for a waitChan while internal queue contains items

17 Nov 05:03
c09fe97
Compare
Choose a tag to compare
  • Prevents FIFO.DequeueOrWaitForNextElement to keep waiting for a waitChan while internal queue contains items

Prevents FIFO.DequeueOrWaitForNextElement to add useless wait channels

04 Mar 06:25
ea2e52e
Compare
Choose a tag to compare
  • Prevents FIFO.DequeueOrWaitForNextElement to add useless wait channels

Prevents FIFO.DequeueOrWaitForNextElement to gets blocked

02 Mar 00:01
a3c75ce
Compare
Choose a tag to compare

Prevents FIFO.DequeueOrWaitForNextElement to gets blocked when waiting for an enqueued element.

Unblocking FixedFifo.Enqueue

24 Feb 21:23
e189583
Compare
Choose a tag to compare

FixedFifo.Enqueue prevents to gets blocked trying to send the item over an invalid waitForNextElementChan channel

DequeueOrWaitForNextElementContext

14 Apr 07:37
dfa38a0
Compare
Choose a tag to compare
  • Added DequeueOrWaitForNextElementContext(...) both for FIFO and FixedFIFO
  • Updated tests:

    FixedFIFO.TestDequeueOrWaitForNextElementMultiGR
    FixedFIFO.TestDequeueOrWaitForNextElementWithEmptyQueue

DequeueOrWaitForNextElement

05 Jun 13:42
4212a49
Compare
Choose a tag to compare

Added DequeueOrWaitForNextElement() both for FIFO and FixedFIFO

FIFO queue

14 Jan 19:24
3b6b0eb
Compare
Choose a tag to compare

First In First Out (FIFO) concurrent queue