@Override
    public int size()
    {
        int size = 0;
        for (MpscArrayQueue<E> lane : queues)
        {
            size += lane.size();
        }
        return size;
    }
Use a set number of parallel MPSC queues to diffuse the contention on tail.
jctools-core/src/main/java/org/jctools/queues/MpscCompoundQueue.java