0

tryPublishEvent関数を呼び出して Disruptor にデータを追加しました。40秒待ってからunprocessedDataCount、次の計算で確認しようとしました:

long ringBufferUnProcessedCount = disruptor.getBufferSize() 
                                  - disruptor.getRingBuffer().remainingCapacity()

値を取得する前に 40 秒待っremainingCapacityても、値が 0 になることがあります。ringBufferUnProcessedCountこのエラーはめったに発生しません。

なぜそうなのかわかりませんか?

4

1 に答える 1