Method RingQueue

core/src/main/java/io/questdb/mp/RingQueue.java:38–58

(ObjectFactory<T> factory, int cycle)

    private long memorySize;

    @SuppressWarnings("unchecked")
    public RingQueue(ObjectFactory<T> factory, int cycle) {
        // zero queue is allowed for testing
        assert cycle == 0 || Numbers.isPow2(cycle);
        try {
            this.mask = cycle - 1;
            this.buf = (T[]) new Object[cycle];

            for (int i = 0; i < cycle; i++) {
                buf[i] = factory.newInstance();
            }

            // heap based queue
            this.memory = 0;
            this.memorySize = 0;
            this.memoryTag = 0;
        } catch (Throwable th) {
            close();
            throw th;
        }
    }

    @SuppressWarnings("unchecked")
    public RingQueue(DirectObjectFactory<T> factory, long slotSize, int cycle, int memoryTag) {