Disruptor 源码分析(10) 位置信息是否ok的标识
位置信息是否ok的标识
在生成者中是通过RingBuffer的pulish方法来修改的
调用顺序是这样的:
public boolean isAvailable(long sequence) { int index = calculateIndex(sequence); int flag = calculateAvailabilityFlag(sequence); long bufferAddress = (index * SCALE) + BASE; return UNSAFE.getIntVolatile(availableBuffer, bufferAddress) == flag; }