I am curious why you decided to implement blocking queue on top of JCtools' MPSC vs using disruptor that implements it. https://github.com/conversant/disruptor https://github.com/conversant/disruptor/blob/master/src/test/java/com/conversantmedia/util/concurrent/DisruptorBlockingQueueTest.java
I do not have experience or stake in using either of those, but conversant claims to be faster and it already has blocking queue API. [ Full content available at: https://github.com/apache/bookkeeper/pull/1682 ] This message was relayed via gitbox.apache.org for [email protected]
