Class AbstractSequence

core/src/main/java/io/questdb/mp/AbstractSequence.java:29–48

import io.questdb.std.Unsafe;

public abstract class AbstractSequence extends RhsPadding {
    private static final long CACHE_OFFSET = Unsafe.getFieldOffset(Value.class, "cache");
    private static final long VALUE_OFFSET = Unsafe.getFieldOffset(Value.class, "value");

    public AbstractSequence(WaitStrategy waitStrategy) {
        super(waitStrategy);
    }

    protected boolean casValue(long expected, long value) {
        return Unsafe.cas(this, VALUE_OFFSET, expected, value);
    }

    protected long getValue() {
        return Unsafe.getLong(this, VALUE_OFFSET);
    }

    protected void setCacheFenced(long cache) {
        Unsafe.putOrderedLong(this, CACHE_OFFSET, cache);
    }
}

@SuppressWarnings("unused")
class LhsPadding {