I work for Striim. We altered MpscCompoundQueue for our own purposes and wish to offer the result back to your project. Our MpscBlockingQueue creates multiple internal queues to receive events efficiently while also blocking when the queue is full.

MpscBlockingQueue.java

If this is something you are interested in I will clean up the symbol names and match the formatting to your style.