- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
您好!首先让我说一下,我们是 Akka 的新成员
我们处于一种奇怪的情况,我们想通过 actorSelection
方法使用其路径来解析一个 actor,但在源代码中的许多情况下都会解析该路径,除了一个特定的。我们在 android 中,我们有一个 Receiver
,它激活一个 actor 发送各种消息的过程。有时这一系列消息会完成,但我们不会终止 actor 系统。
然后还有一个Receiver正在被调用。在该接收器中,actor 系统 仍然存在,因为它已保存在一个object var 中。使用那个 actor 系统,我们试图解析 actor,但是无论解析超时有多大,都无法找到 actor。 我们不确定 actor 是否已经死亡,但是代码非常干净,所以可能没有在 actor 中抛出任何异常。
注意:一个 actor 的 child 在父 actor 的构造函数中被创建为 private val ...
(不确定这是否是最好的策略) )
首先,因为 actorSelection
返回一个 future ,我们使用 Await.result
方法来获取这个 future 的值。其次,我们在许多不同的设备上尝试了各种 android api,并尝试了不同版本的 akka-library。
您是否知道可能会发生什么,或者知道我如何准确了解正在发生的事情,而这个 actor 解析失败了?
由于广播接收器的生命周期,从 BroadcastReceiver
内部尝试从一开始就注定要失败。所以起初 Android 似乎是罪魁祸首,我们必须创建两个服务。一个远程 Service
(粘性),用作存储 ActorSystem
的进程。但是因为从 BroadcastReceiver 内部绑定(bind)到服务是不可能的,我们不得不创建一个 IntentService
来充当 BroadCastReceiver 和 IntentService 之间的中介。
不幸的是,结果还是一样。一切正常,除了 actor 无法解析。
我们对无法解决的 actor 进行了死亡监视,但结果仍然相同,我们无法收到任何 Terminated 消息。在上述失败尝试之后,我们尝试创建一个全新的项目,删除所有不必要的代码。这种努力的结果是错误消失了!(可能)。因此,我们必须得出结论,我们的一些原始代码首先应归咎于被破坏的 Actor 。
最佳答案
你的问题缺少很多有用的信息(例如关于哪个 Actor 在哪个路径查找其他 Actor 路径),但我的主要怀疑是你在父级中使用 Await.result
要查找的 actor 的名称,这会阻止消息发送到该 actor(因为每个父级都需要在幕后转发消息——这在 2.3.0 中得到了改进)。
关于android - 无法使用 actorSelection 解析 Akka actor,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/22275631/
我有一个数据框: title | cast ------------------------------ movie1 | cast1,cast2,cast3 movie2
据我所知,Actor 模型是一种关于并发的理论。 Erlang 和 Scala 都实现了这个理论模型,但它们的实现都不完全符合 Actor 模型。 从计算机科学家的角度来看,Erlang、Scala
我是 akka 流的新手。我将 kafka 用作源(使用 ReactiveKafka 库)并通过流对数据进行一些处理并使用订阅者 (EsHandler) 作为接收器。 现在我需要处理错误并通过错误处理
考虑以下代码示例(版本 1)。此处父 actor (ActorA) 向子 actor (ActorB) 发送消息,然后停止自身。由于父 actor 的自停止,在高负载下,子 actor 甚至在从邮箱中
我有以下 Scala 代码: package dummy import javax.servlet.http.{HttpServlet, HttpServletRequest => H
如何描述“数据流编程”和“ Actor 模型”之间的区别?据我了解,它们并非无关,但又不相同。 DF 是否是一个更广泛的概念,其要点是与控制流模型的区别,而 Actor 模型是更详细的和理论上有根基的
GPars 中的 Actor 有自己的消息队列(邮箱)。假设一个参与者有 15 条待处理的消息,然后系统突然宕机(比如由于电源故障)。这 15 条消息会发生什么。当系统再次启动并运行时,消息队列会自动
我刚刚开始使用 AKKA,并且有一个关于非参与者代码如何与参与者代码对话的基本问题。 非参与者代码如何调用参与者并获得响应?我试过使用 Patterns.ask 从非 Actor 调用 Actor ,
这个问题在这里已经有了答案: 关闭 9 年前。 Possible Duplicate: Casting vs using the ‘as’ keyword in the CLR 我最近了解到一种不同
我在设置边界矩形位置时遇到麻烦,这就是我问这个的原因。当我设置 Actor 类型的对象的边界矩形位置时,看来我传递给 [setBounds(x,y,with,height)] 2 的坐标相对于 Act
我是 Actor 模型的新手。任何人都可以解释 Actor 模型中 Actor 的生命周期吗?我一直在文档中寻找答案,但找不到任何令人满意的内容。 我对 Actor 完成后做什么很感兴趣onRecei
例如,我有两个 Actor ——一个父 Actor 和一个子 Actor 。当 parent 收到一条消息时,它会产生与消息中指定的一样多的子actor。如何测试此功能?有没有办法模拟上下文或其他方法
我目前在 Futures 编程,我对 Actor 很好奇。我想听听有经验的声音: Actor 相对于 future 有什么优势? 我什么时候应该使用一种而不是另一种? 据我所知, Actor 持有状态
Actor 模型框架(例如 Orleans )和复杂事件处理 (CEP)(例如 Apache Storm )之间有什么区别? 其中每种方法都适用(或者一种方法比另一种方法更适用)的使用示例肯定会有所帮
你们中的任何人都可以帮助我理解传入的基本消息吗scala 使用 Actor 模型? 我正在尝试编写一个包含 3 个 Actor 的简单程序。 Actor “BossActor”创建了 2 个 Acto
Akka 1.1.3 文档指出“become 方法对于许多不同的事情都很有用,但它的一个特别好的例子是它用于实现有限状态机 (FSM) 的示例”。在运行时热交换 Akka actor 的实现还有哪些其
我正在尝试使用参与者实现消息处理管道。管道的步骤包括读取、过滤、扩充以及最后存储到数据库中等功能。类似于此:http://sujitpal.blogspot.nl/2013/12/akka-conte
可以使用 actor.send() 或 actor.offer() 向 Actor 发送消息一旦我的 Actor 从其 channel 收到消息,我想返回响应。我该怎么做呢?我没有看到任何明显的内置方
你们中的任何人都可以帮助我理解传入的基本消息吗scala 使用 Actor 模型? 我正在尝试编写一个包含 3 个 Actor 的简单程序。 Actor “BossActor”创建了 2 个 Acto
我目前正在尝试保存特殊 Actors所以如果加载旧 map ,我可以再次将它们放在 map 上。因此我想将它们放入 HashMap> monsterAtMap 中并从那里删除它们Stages .所以我
我是一名优秀的程序员,十分优秀!