TL;DR; パフォーマンスの高い永続的なブロック キューを備えたライブラリがあるかどうかを知る必要があります。
私は古典的な生産者/消費者プログラムを持っています。それらLinkedBlockingQueue
はデータを共有するために a を共有しBlockingQueue#take
、新しい要素を待って永遠に生き続ける必要があるため、Consumer でメソッドを使用します。
問題は、大量のデータがあり、それらを失うことができないことです。コンシューマーが停止した後でも、プロデューサーは持続してデータを生成できます。H2
BlockingQueue ta を実装して、しきい値に達した後にデータを保存/取得することを考えています。私の主な問題は、パフォーマンスが必要であり、作成された順序で要素を消費する必要があることです。
このようなものに使用できる永続的なブロッキング キューの実装はありますか? そうでない場合、このようなことを達成するための提案はありますか?