次の機能を提供するWorkQueueAPIを探しています。
java.util.Queue
互換性- オファー(オプション)セットセマンティック
- 単一およびバッチ処理
- 並行性(もちろん)
- スケジューリング
- さまざまな処理ポリシー
- 次のスケジュールされた実行まで待つ
- バッチサイズが満たされた場合、前処理
- 処理の遅延(処理される前のキュー内の最小時間)
- 永続性(オプション)
jdkには興味深い実装がたくさんあります。たとえばjava.util.DelayQueue
、私が使用できるものなどです。車輪の再発明をしていないことを確認したかっただけです。