actor

1热度

1回答

下面的演员表演一次，分子和分母都收到一个部门， package funnelTest import akka.actor.{Actor, ActorSystem, Props} object Main extends App { val system1 = ActorSystem("funnelTest") val input = system1.actorOf(Pr

2热度

1回答

Akka从另一个树枝跳过演员

我有几个演员的Akka应用程序。演员树看起来像这样： /user /one TARGET /two /three SOURCE 在源演员我必须发送消息到目标演员。但是，我不知道如何正确地做到这一点。从ActorSelection解析ActorRef似乎每次都很糟糕。是否有任何图案？

2热度

1回答

libgdx演员不会更改位置

如果演员被自己的actor.act()方法移动，它会完美地更新位置。但是，如果我通过包含演员的group（其中包含演员，moveBy()方法或moveBy动作）将演员移动，演员将移动，但其getX（）和getY（）值与移动之前保持相同。当他没有被act()方法移动，而是来自外部方法时，是否有方法让演员更新其位置？的片段看起来是这样的：协调当地演员的 //Bounds are set in the

2热度

1回答

阿卡+ Java的：集演员，而使用RoundRobinPool

我试图用RoundRobinPool路由器创建一些演员的名字： workerRouter = this.getContext().actorOf(new RoundRobinPool(5).props(Props.create(MyWorker.class)), "workerRouter"); 但我无法弄清楚如何唯一的名称分配给每个创建的演员。任何想法？

1热度

1回答

从Akka Actor MailBox（Scala）清除所有邮件

是否有方法清除演员邮箱中的所有邮件？其实，我需要用一些频率（例如1秒）来完成。如果是 - >最简单的方法是什么？

2热度

2回答

如何在actor模型中实现MVCC

假设我已将Employee Employee实体表示为actor。我有2个服务也被模仿为演员。他们两个都通过发送消息来操纵收到的员工的状态。现在我们假设两个服务正在处理同一个actor。现在，它是完全可能的雇员演员按以下顺序接收来自两个服务的一个状态改变的消息和B Employee <- |a1|a2|a3|b1|b2|b3| 这是好的。但有时它不是 Employee <- |a1|b1|a2|b

0热度

1回答

自定义akka邮箱配置（斯卡拉）

我创建了我的自定义邮箱，名为CustomMailBox，它源自MyUnboundedMessageQueueSemantics特质。然后我把这个配置到application.conf： custom-dispatcher { mailbox-requirement = "com.MyUnboundedMessageQueueSemantics" } akka.actor.

0热度

1回答

斯卡拉阿卡系统actorRef包装器

如何定义包装函数/ addActorToSystem()类 trait Stage extends Actor class Stage1(i:Int) extends Stage class Stage2(i:Int) extends Stage 和 implicit val system = ActorSystem("mySystem") ，而不是调用 system.actorOf(

1热度

2回答

Akka演员池用于阻止请求

我正在尝试使用线程池来发起阻止请求。问题是，每个请求都会阻塞整个池，并且项目将按顺序进行处理。不知道这是否可能。有人请帮助 city-dispatcher { type = Dispatcher executor = "thread-pool-executor" thread-pool-executor { fixed-pool-size = 16

1热度

1回答

使用演员监督，如何在发生故障时

我下面从akka.io容错http://doc.akka.io/docs/akka/current/java/fault-tolerance.html .I代码reference.My要求如下采取这种代码重试相同的消息与定义的间隔时间定义的数字：让我们假设演员在消息上崩溃，并由其主管重新启动。然后他开始在他的邮箱中处理下一个消息。这导致崩溃的消息是 “dropped'.But我要处理的时间的