actor

1热度

1回答

在一个简单的测试中，我期待流生成和打印数字一秒钟。我想测试处理背压的流操作，并且需要不支持背压的Source。 ... with FreeSpec ... { implicit val system = ActorSystem(this.getClass.getSimpleName) private val matSettings: ActorMaterializerSett

0热度

1回答

由java测试演员在akka和有ActorInitializationException

我想要使用从演员测试创建演员样本code.but通过运行actor测试抛出ActorInitializationException。我的目标是看到演员试验的测试目标，我使用JUnit测试，但我的类代码下： public class Worker extends AbstractActor { private ActorSystem system = ActorSystem.create("w

0热度

1回答

在类Actors.FileObserverActor上找不到匹配的构造函数，用于参数

我正在尝试使用akka演员在播放frmework中使用websocket。 HomeController.scala def socket = WebSocket.accept[String, String] { request => ActorFlow.actorRef(out => FileObserverActor.props(out)) } 演员/ FileUplo

11热度

2回答

由于为ActorSystem启用了“akka.jvm-exit-on-fatal-error”，因此线程关闭JVM时未捕获到错误

我在命令提示符下运行程序集jar文件，并在下面得到异常。并导致终止。从线程未捕获的错误[CCP-akka.persistence.dispatchers.default-插件，调度-23]因为 'akka.jvm-出口的致命错误' 的ActorSystem启用关闭JVM [中共] 在我的Windows机器上没有别的东西在运行，而这个。除了jar文件外，没有任何代码访问。什么可能是这个问题，我

-1热度

2回答

基于Actor的编程语言中的死锁

在Scala或Elixir等基于演员的语言中仍然会出现死锁吗？如果是，如何检测并避免它们？

0热度

1回答

饥饿谁参加一个序列过程

Bisuness逻辑我们有以下业务逻辑来完成： 100万次这样做：下载索引文件我解压文件从文件中提取一些信息删除文件当前阿卡解决方案的阿卡的解决方案，我们目前所面对的创造百万的演员谁是负责一个要下载的文件，一旦他们这样做，他们创造一个演员照顾2,3,4步骤。问题一旦我们运行的过程中，我们遇到了在阿卡高度重视下载者的情况，演员的休息饥饿模式beeing。我们知道，随着机器磁盘变满

1热度

1回答

使用Akka创建消息环的死信

我想创建一个使用远程actor的示例Akka应用程序。目标是创建例如16个以顺序方式交换消息的演员（演员16与演员15,15到14等会谈，并且1与演员16会谈）。但是，我在通信方面遇到了问题，因为我连续出现此错误。 [INFO] [2017年5月4日15：45：58.248] [ActorFlasks-akka.actor.default-调度-4] [阿卡：// ActorFlasks/dead

3热度

1回答

如何使ServiceFabric演员在遥远的未来熄灭

所以，如果我有一个演员，我用的是以下行： await RegisterReminderAsync("My Reminder", new byte[0], TimeSpan.FromDays(30), TimeSpan.FromSeconds(60)).ConfigureAwait(false); 我可以设置提醒，30天走下车，用了一段60秒。但是，如果我尝试设置提醒在60天后关闭，则

1热度

1回答

当setFillParent为true时，演员的位置是错误的，在LibGDX

我已经花了几个小时试图解决这个问题，并且我疯了，请看看我的问题。图片示出了此问题： Image illustrating this 当exitButton的setFillParent功能被设定为false的结果是图像的右边，按钮居中内的Container但大小是错误的。当exitButton的setFillParent功能被设置为所述true结果是图像的左侧，按钮的尺寸正确地但位置是错

0热度

2回答

Scala akka演员系统 - RuntimeException当加载扩展

我是新的scala和我面临以下问题。 import akka.actor.Actor import akka.actor.Props import akka.event.Logging import akka.actor.ActorSystem object test extends App { val system = ActorSystem("hello-world")