JCTools / JCTools / 700

88%

push

travis-ci

MpscBlockingConsumerArrayQueue poll with timeout fix (#316)

MpscBlockingConsumerArrayQueue poll with timeout fix

Previously the following sequence was possible:
```
  Consumer                            Provider

  poll(timeout)
                                      offerAndWakeup()
  time out
                                      soRefElement(, offset,)
  consume from offset
  offset -> offset'
  poll()
                                      soBlocked(null)
                                      unpark(consumerThread)
  // Spin for ever
  spinWaitForElement(, offset')
```
Issue resolved by more strictly enforcing consumer invariants when exiting the parked state.

Co-authored-by: nickhill <nickhill@us.ibm.com>
Co-authored-by: Nitsan <nwakart@gmail.com>

43 of 43 new or added lines in 1 file covered. (100.0%)

4766 of 5541 relevant lines covered (86.01%)

0.86 hits per line