Scala中多个Actor的实现有何不同？
随着Scala 2.9.0的发布，还宣布了Typesafe Stack，它结合了Scala语言和Akka框架。现在，尽管Scala在其标准库中有参与者，但Akka使用其自己的实现。而且，如果我们寻找其他实现，我们还会发现Lift和Scalaz也有实现！ 那么，这些实现之间有什么区别？ 解决方案 这个答案不是我的。 它是由大卫·波拉克（David Pollak）制作（阿卡名望） （是L
..
actor相关内容
Scala演员-最坏的做法？
我对于在Scala中使用演员有些不安全。我已经阅读了有关如何操作的文档，但我想我还需要一些不要使用的规则，以便随时使用它们。 我想我会以错误的方式使用它们，我什至不会注意到它。 您能想到一些如果应用的话会导致Scala演员所带来的利益破灭甚至出现错误的结果吗？ 解决方案 避免 ！？ 。您将获得锁定的系统！ 始终从Actor子系统线程发送消息。如果这意味着通过 Actor.
..
在Scala中，单撇号是什么意思？
在此幻灯片中， ScalaActors.pdf 上的单引号是什么指示何时将消息发送给乒乓球演员？ 类Ping（count：int，pong：Pong）扩展Actor { def act（）{$ b $ p！ ‘Ping //单引号表示什么？？？ 收到{ 案‘Pong => } } } 解决方案 它表示一个符号。例如。 cfr http://www.scala-la
..
Scala中的并行文件处理
假设我需要并行处理给定文件夹中的文件。在Java中，我将创建一个 FolderReader 线程，以从该文件夹中读取文件名以及一个 FileProcessor 线程池。 FolderReader 读取文件名，并将文件处理功能（ Runnable ）提交给池执行器。 在Scala中，我看到两个选项： 创建 FileProcessor actor并使用 Actors.Scheduler 安
..
如何将参与者消息限制为特定类型？
在 Akka 中，除了使用“类型化的参与者” API之外，还有一种方法可以将消息限制为特定静态类型的参与者 我可以在Akka中使用消息传递样式，而不会在角色边界处放弃静态类型安全性吗？ 例如，我想使用如下代码： 密封的抽象类FooMessage 案例对象Foo扩展了FooMessage 案例对象Bar扩展了FooMessage 类FooActor扩展了Actor [Fo
..
奥尔良粮食上的任务调用结果
很长的问题我深表歉意。我一直在与奥尔良进行试验，以了解其各种特性，并且从逻辑上讲，这些问题都归根结底。 第一个测试涉及每1秒从客户端向特定谷物发出请求，而谷物则需要10秒才能执行要求。代码是这样的： //客户代码 而（1） { Console.WriteLine（“客户端发出另一个请求”）; double temperature = random.NextDouble（）*
..
在Play框架中设置亲子演员
我刚刚开始使用Play Framework + Akka.我有一名家长演员和一名儿童演员(将来可能会超过).我正在从控制器发出Api呼叫，并期待儿童演员的回应. NotificationController: @Singleton public class NotificationController extends Controller{ final ActorRef com
..
Akka的语言和产品替代品有哪些?
现在我正在查看 Play框架，并且非常喜欢.在Play提供的功能中，广为宣传的部分之一是 Akka . 为了更好地了解Akka以及如何正确使用Akka，您能告诉我其他语言或产品的替代方案是什么吗? RabbitMQ 与之相比如何?有很多重叠吗?一起使用它们是否可行?在什么用例中? 解决方案 最好的起点是很棒Akka官方文档.我认为最接近Akka的产品/框架是 erlang 语言
..
持久的Akka邮箱和无损
在Akka中，当演员在处理消息时死亡(在onReceive(...) { ... }内部，该消息丢失了.有没有办法保证无损?有没有办法将Akka配置为始终在之前保留消息将它们发送到onReceive，以便在演员死后可以对其进行恢复和重播? 也许像一个永久邮箱? 解决方案 是的，看看
..
Scala中的Akka，感叹号和问号
向Actor发送消息时，感叹号(!)和问号(?)有什么区别? myActor ! Hello(value1) myActor ? Hello(value1) 解决方案 无耻复制 [awesome] 通过以下方法之一将消息发送给Actor. !的意思是“一劳永逸"，例如异步发送消息， 立即返回.也称为tell. ?发送一条消息 异步返回Future表示可能的答复. 也称为a
..
如何使用Scala演员
如何使用Scala Actor解决此问题: 我有一个程序可以找出给定路径下文件中标识符的频率.假定的编码为UTF-8.我想用scala actor解决同样的问题. //program to find frequencies of identifiers import java.io._ import java.util.concurrent._ import java.util.concur
..
更换游泳池中表现不佳的工人
我有一组角色，这些角色有些无状态，并且执行类似的任务. 这些工人中的每一个都不可靠，并且可能表现不佳.在我的设计中，我可以轻松产生更多的演员来代替懒惰的演员. 演员的表演由他自己来评估.有没有一种方法可以使主管/演员池进行此评估，以帮助确定哪些工人足够慢以便我替换?还是我当前的策略是“正确的"策略? 解决方案 我本人是akka的新手，所以只想提供帮助，但是我的攻击将遵循以下几条原则:
..
Akka参与者如何在基础线程上实现?
鉴于执行上下文和线程池，如何在其上计划/实现akka/scala actor? 解决方案 我很长时间以来一直对此主题感到困惑.我假设线程和参与者之间存在某种关系.每个演员都有一个主持它的线程，所以我在想.在协作多任务模式下工作的每个线程可能都有几个参与者. 文档侧重于用法，并简要介绍了内部体系结构.您只需要扩展Actor类，您就可以成为演员.因此，我试图猜测如何做到这一点.并想象每个
..
如何为参与者指定线程池
我有一个使用全局线程池的现有Java/scala应用程序.我想开始在项目中使用actor，但希望应用程序中的所有内容都使用同一池. 我知道我可以设置actor使用的最大线程数，但希望共享线程池.这是必要/合理的，并且可以指定参与者的线程池吗? 如果不可能/建议，在将actor集成到已经使用线程的应用程序中时，有什么经验法则吗? 谢谢. 解决方案 我相信您可以执行以下操作:
..
Scala演员:接收与反应
首先让我说我有很多Java经验，但是直到最近才对函数式语言感兴趣.最近，我开始研究Scala，这似乎是一种非常不错的语言. 但是，我已经在 在Scala中编程中了解了Scala的Actor框架. ，有一件事我不明白.在第30.4章中，它说使用react代替receive使得可以重用线程，这对性能有好处，因为JVM中的线程很昂贵. 这是否意味着，只要我记得叫react而不是receive
..
Akka和ReactiveMongo
我正在尝试找到最佳方法，与集群工作者在参与者之间共享相同的连接池.我有以下结构: 主要演员->工人演员(最多100个或更多)-> MongoDB 在工作人员和MongoDB之间，我想放置reactmongo，但是我不确定如何在所有参与者之间提供连接池共享. 根据reactmongo文档: MongoDriver实例管理参与者系统；连接管理连接池.通常，MongoDriver
..
Scala actor消息定义
我需要为要在scala actor上检索的消息定义类吗? 我试图把它弄醒 我在哪里错了 def act() { loop { react { case Meet => foundMeet = true ; goHome case Feromone(qty) if (foundMeet == true) => s
..
将Akka演员包装在类中是否会导致内存泄漏?
我有一个围绕scala akka actorRef的相当基本的包装器类.基本上，该类具有一个字段，它是actorRef，并提供了许多将特定消息“告知" actorRef的方法.通过这种方式，我可以遵循指定的API，并避免暴露出Tell或Message类.我在程序中遇到了内存泄漏，我想知道我的Akka演员包装器是否引起了问题.我在下面编写了此模拟程序以检验我的理论. import akka.a
..
演员邮箱溢出.斯卡拉
我目前在斯卡拉与两个演员合作.一个是 producer ，它产生一些数据并将其发送到 parcer .生产者通过消息发送HashMap[String,HashMap[Object,List[Int]]](连同 this 标记发送者): parcer ! (this,data) 解析器一直在等待消息，例如: def act(){ loop{ react{
..
Akka actor日志未写入文件
我正在尝试登录文件而不是stdout. 我的application.conf(在src/main/resources/中): akka { event-handlers = ["akka.event.slf4j.Slf4jEventHandler"] loglevel = "DEBUG" } logback.xml(在src/main/resources/中):
..