我用
Java实现了我称之为“可折叠队列”的东西,即ExecutorService使用的LinkedBlockingQueue.这个想法是每个任务作为唯一的id,如果在队列中,而另一个任务是通过相同的id提交的,则它不会被添加到队列中. Java代码如下所示：
public final class FoldablePricingQueue extends LinkedBlockingQueue<Runnable> {
@Override
public boolean offer(final Runnable runnable) {
if (contains(runnable)) {
return true; // rejected,but true not to throw an exception
} else {
return super.offer(runnable);
}
}
}
线程必须预先启动,但这是一个小细节.我有一个Abstract类,它实现了Runnable,它接受一个唯一的id …这是传入的
我想用Scala和Akka(Actors)实现相同的逻辑.
我需要访问邮箱,我想我需要覆盖！方法并检查邮箱的事件..有没有人以前做过这个？
解决方法
这正是Akka邮箱的工作原理. Akka邮箱只能在任务队列中存在一次.
看着：
使用原子布尔值非常便宜地实现,因此不需要遍历队列.
顺便说一句,你的Java中的队列是破坏的,因为它不会覆盖put,add或offer(E,long,TimeUnit).
