Scala折叠使用Akka
发布时间：2020-12-16 18:03:08 所属栏目：安全 来源：网络整理
导读：我用 Java实现了我称之为“可折叠队列”的东西,即ExecutorService使用的LinkedBlockingQueue.这个想法是每个任务作为唯一的id,如果在队列中,而另一个任务是通过相同的id提交的,则它不会被添加到队列中. Java代码如下所示： public final class FoldablePrici
|
我用
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邮箱只能在任务队列中存在一次.
看着： https://github.com/jboner/akka/blob/master/akka-actor/src/main/scala/akka/dispatch/Dispatcher.scala#L143 https://github.com/jboner/akka/blob/master/akka-actor/src/main/scala/akka/dispatch/Dispatcher.scala#L198 使用原子布尔值非常便宜地实现,因此不需要遍历队列. 顺便说一句,你的Java中的队列是破坏的,因为它不会覆盖put,add或offer(E,long,TimeUnit). （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |