0

1つのスレッドに1つのスレッドと1つのCronジョブ(スレッド)が15分ごとに実行され、キューからすべての要求を受け取り、キューを空にします。キューを消費するコンシューマとブロック化キューの同期を維持する方法

どのようにしてこの同期を管理し、システム内で要求が失われていないことを確認できますか。 同じものに対してLinked Queueを使用することを考えました。 他の提案を歓迎します。 私はJavaに慣れていないので、この素朴な質問をしています。

+0

['BlockingQueue.drainTo(Collection)'](https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html#drainTo-java.util.Collection- ):*このキューから使用可能なすべての要素を削除し、指定されたコレクションに追加します* – Holger

答えて

0

java.util.concurrentパッケージでは、あなたの処分に必要なキューがたくさんありますが、上記のシナリオのキューだけがあるとは思いません。

ブロッキングキューの1つを選択し、並行して15分ごとにキュー内のすべてのアイテムを排除するジョブを実行することをお勧めします。

関連する問題