@Override
    public int fill(Supplier<E> s)
    {

        return MessagePassingQueueUtil.fillBounded(this, s);
    }
Use a set number of parallel MPSC queues to diffuse the contention on tail.
jctools-core/src/main/java/org/jctools/queues/MpscCompoundQueue.java