tryPublishEvent
我通过调用函数将数据添加到 Disruptor 。在我等待 40 秒并尝试unprocessedDataCount
通过以下计算进行检查后:
long ringBufferUnProcessedCount = disruptor.getBufferSize()
- disruptor.getRingBuffer().remainingCapacity()
有时remainingCapacity
值等于 0,即使在获得ringBufferUnProcessedCount
值之前我们等待 40 秒。这个错误很少发生。
你不知道为什么会这样吗?