algorithm - 为Akka Actor 池排序了共享邮箱或总线？

As it currently stands, this question is not a good fit for our Q&A format. We expect answers to be supported by facts, references, or expertise, but this question will likely solicit debate, arguments, polling, or extended discussion. If you feel that this question can be improved and possibly reopened, visit the help center用于指导。
我试图同时学习scala和akka，这很神奇，但有时也有点混乱，我很抱歉我的问题支离破碎。
我了解演员模型有参与者，他们发送和接收消息，他们有一个邮箱来存储接收到的消息，邮箱可以对消息进行优先级排序，然后一切都变得混乱。
我读了很多书，读得越多，我就越困惑，所以我希望有人能提供一些帮助，把困惑程度降低到可以接受的最低限度指针是受欢迎的，但我可能需要一些小的胶水解释，把所有的东西放在一起，基本上是一些对rtfm的帮助。
问题是：
如何在收件箱中对邮件进行排序？我读过关于“隐式”（在有序邮箱中）的文章，但听起来很神奇。我以为排序后的邮箱只接受实现Comparable接口的类型，但是Scala使用函数范型，如果我没有弄错的话，它接受一个ordering函数，返回一个Ordering[T]然而，排序功能（处理T？）可能仅限于可比较的对象，所以，返回到Comparable？
有没有可能共享邮箱？
这里应该使用总线的一些实现吗公共汽车能分类吗？
什么是implicit abstract def它看起来像一个应该实现（abstract）但不需要实现（implicit）的方法，这听起来很矛盾（这是SortedSet中的定义）
我应该定义一个Dispatcher我还没搞清楚这在整个体系结构中是如何匹配的。但我一直在寻找游泳池，却找不到调度员。
我应该读一下关于Futures的书吗？我试图做一个小的实现，逐步掌握概念，在阅读和编程的循环。很抱歉又问了这么多问题。
到目前为止，我认为的解决方案是：
具有作为通信中心节点的参与者。
这个中心参与者保持一个SortedSet的位置，将要发送到参与者池的消息在这里排队
这个中心角色还保留了一个Set的自由角色。
当一个参与者空闲时（在处理完任何消息后），自由参与者会向中心参与者发送一条消息，要求做一些工作。
中心参与者处理消息：
如果存在挂起的工作，则会将需要处理的消息出列。
如果没有工作要做，则存储对自由代理的引用，以便向他发送一些工作。
中心参与者以类似的方式处理带有作业任务的消息。
如果有免费的演员，那么这个工作就交给一个免费的演员。
如果没有空闲的参与者，则将作业添加到SortedSet。
参与者池是通过简单地创建它们并将它们的所有引用发送到中央管理器来创建的。
我之所以想到这个解决方案，是因为我对Scala和Akka都不太了解但我不想永远被这种解决方案困住基本上，一个演员可以做任何事情，但我想正确地使用它们，并正确地使用所有其他元素，如邮箱、总线、池、调度器、未来等等。
非常感谢你。

最佳答案

1&2&5:Akka关于dispatcher s的文档很好地解释了什么是dispatcher以及如何定义和使用dispatcher它还记录邮箱、如何定义自己的、可能具有优先级的邮箱以及多个参与者如何共享单个邮箱：
http://doc.akka.io/docs/akka/2.1.4/java/dispatchers.html
3:afaik是akka中的默认EventBus，不允许对消息进行排序
4:implicit abstract def定义了一个abstract方法，它也是implicit。隐式和抽象成员是正交的概念，所以这里没有矛盾。也许您想定义一个隐式转换并将其实现委托给一个子类。
6:是的，未来是一个重要的部分，不仅仅是在Akka中，对于Scala的并发来说也是如此。
对于您的特定设计问题，也许一个更简单的解决方案是使用路由器。路由器是一种特殊的参与者，它根据策略将传入的消息发送给注册的路由对象。
http://doc.akka.io/docs/akka/2.1.4/scala/routing.html
在你的情况下，你可以用路由器代替你的中心角色如果您的邮件需要设置优先级，您可以为该路由器配置优先级邮箱。
接近您描述的行为的路由器是SmallestMailboxRouter。
如果您确实决定需要使用一个收集消息的中心参与者，那么在监督该参与者时要非常小心。默认情况下，失败的参与者将重新启动，因此您可能会丢失保存消息的SortedSet。这是使用自定义邮箱的另一个原因：将actor状态与消息排序语义分离。

关于algorithm - 为Akka Actor 池排序了共享邮箱或总线？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/16942941/

上一篇：java - Java中使用二分查找实现二分插入排序

下一篇：algorithm - 归并排序的变体

python-3.x - 生成缩短网址的代码/算法是什么？

java - 如何在 Scala 中实现真正的单例

javascript - 为什么使用 < 和 > 对排序功能没有影响？

php - magento - 使用自定义属性的 addAttributeToSort 对产品集合进行排序 - 不起作用

java - 即使在奇数之前，也使用递归按升序排列

algorithm - 二叉树中序遍历Racket

multithreading - 环形缓冲区，1 个写入器和 N 个读取器

android - 如何在 SBT 中向 Jan Berkel 的 Android 插件添加更多类似的任务和设置？

scala - 指定抽象类型成员