tryPublishEvent
関数を呼び出して Disruptor にデータを追加しました。40秒待ってからunprocessedDataCount
、次の計算で確認しようとしました:
long ringBufferUnProcessedCount = disruptor.getBufferSize()
- disruptor.getRingBuffer().remainingCapacity()
値を取得する前に 40 秒待っremainingCapacity
ても、値が 0 になることがあります。ringBufferUnProcessedCount
このエラーはめったに発生しません。
なぜそうなのかわかりませんか?