RingBuffer.java

public class RingBuffer<T> {
    public RingBuffer(int size) {
        this.capacity = Bits.powOf2(size);
        this.mask = capacity - 1;
        buffer = new Object[this.capacity];
    }

    private int offset(int index) {return index & mask;
        //return index % capacity;
    }
    public boolean write(T value) {
        if (buffer[offset(write)] != null)
            return false;
        buffer[offset(write++)] = value;
        return true;
    }
    public T read() {
        if (read == write)
            return null;
        T value = (T) buffer[offset(read)];
        buffer[offset(read++)] = null;
        return value;
    }
}