bfe18bcb3c
Motivation: peek() is implemented in a similar way to poll() for the mpsc queue, thus it is more like a consumer call. It is possible that we could have multiple thread call peek() and possibly one thread calls poll() at at the same time. This lead to multiple consumer scenario, which violates the multiple producer single consumer condition and could lead to spin in an infinite loop in peek() Modification: Use isEmpty() instead of peek() to check if task queue is empty Result: Dont violate the mpsc semantics. |
||
---|---|---|
.. | ||
src | ||
pom.xml |