Pet*_*ter 6 java queue concurrency timedelay deduplication
大家好,
我有一个系统(源)需要在某些对象发生变化时异步通知另一个系统(目标).扭曲是源系统可能在短时间内多次突变单个对象(更新非常"突发"),在这种情况下,理想的情况是仅通知目标系统一次,并且最终状态为宾语.
我的想法是在ThreadPoolExecutor前面使用某种延时的重复数据删除队列.这个队列会:
将项目保留在队列中的时间最短(理想情况下配置为仅比典型突发突发的持续时间长的smidgin)
如果重复(由对象的标识符定义)入队,则替换现有对象.但是,该项目应该保留在队列中的原始位置(以避免任何一个项目永久地碰到队列的后面 - 在某些时候我们需要发送通知,即使另一个项目将暂时出现).
我在java.util中没有看到任何完全相同的东西,而我在这方面的google-fu似乎特别弱.
有没有人以前实现过这个,知道一个行为方式的BlockingQueue实现,或者有关于如何实现一个的提示？
提前致谢!
彼得
PS.我知道ESB会做这种事情,但在这种情况下,这是一种过于重要的方法 - 理想情况下,我根本不想在源系统中添加任何新的库依赖项.
我认为你最好的选择是扩展ArrayBlockingQueue和覆盖offer并poll添加时间延迟功能。特别是ArrayBlockingQueue因为它有一个contains方法。
另一个想法是DelayQueue您重写offer以删除旧元素并插入新元素，但保留旧的时间延迟，这基本上会保留顺序。然后您需要将队列项目包装在Delayed界面中。