Method close

core/src/main/java/io/questdb/mp/RingQueue.java:82–91

()

    }

    @Override
    public void close() {
        for (int i = 0, n = buf.length; i < n; i++) {
            buf[i] = Misc.freeIfCloseable(buf[i]);
        }
        if (memory != 0) {
            memory = Unsafe.free(memory, memorySize, memoryTag);
            this.memorySize = 0;
        }
    }

    public T get(long cursor) {
        return buf[(int) (cursor & mask)];