通过无处不在的异步通信区分的编程模型。
Actor模型:我们可以使用actor模型获得共享锁的语义吗?
一个actor一次处理一个消息并封装它不共享的状态这一事实足以提供同步语义。所以采取互斥(写锁)......
我有以下问题:一个actor与一个用例A相关联,它有一个扩展用例B,B是用例C的扩展。问题:这是否意味着该actor可以访问用例C? ...
我创建了一个简单的场景。以下actor系统:akka.tcp://[email protected]:2560 akka.tcp://[email protected]:2570 akka.tcp://[email protected]:2580想法是创建一个” ...
在Akka中,我向群集添加了两台不同的计算机。但是有一些问题。如果两台机器同时站起来,那么两侧就会离开而不能看到对方。或者因为......
假设我有一个非常简单的actor类,它接收任何消息并打印到控制台。 class SimpleActor扩展了Actor {def receive:Receive = {case message => ...
我目前正在学习面向对象编程的第二部分,我们已经转向了UML。我们正在学习当前的用例和演员,我们需要创建:演员列表和使用...
未正确执行虚幻引擎Actor类的Construction()方法
我正在编写一个C ++的ALadder类,其灵感来自Alan Noon的教程https://www.youtube.com/watch?v=axuwbkDWI5U。目前课程非常简单:Ladder.h #pragma曾经#include“......
我们正在考虑使用Message-broker来实现基于消息的发布 - 订阅通信模式。您是否需要使用Actor-model才能进行基于消息的发布/订阅通信...
我正在开发一个应用程序,它创建一些Akka actor来管理和处理来自Kafka主题的消息。具有相同键的消息由同一个actor处理。我用的是消息密钥......
我开始通过迁移现有的Java SE应用程序来学习Akka。我正在使用Akka 2.0.3。有一次,我需要通过消息队列发送PoisonPill来阻止演员。我的演员是......
我有一个像这个类的演员TcpClientActor(target:Target)使用Logger扩展Actor {覆盖def preStart():Unit = {self! TestConnection}覆盖def接收:Receive = {...
我必须使用.vtp格式(也在vtm中)的一些切片,我想要一起可视化以便在之后处理它们。我已经设置了读者,地图制作者,演员,渲染窗口和相机坐标,但是......
我最近测试了不同的Akka消息处理模块,我发现了一个有趣的现象。基本上我比较了两种情况:1)单一演员与Future来处理消息。 2)......
我有两个vtkSplineRepresentation()和两个视口。我想用Spline绑定一个视图。我知道为了做到这一点,我必须创建一个Actor。但问题是我不知道怎么做。一世 ...
我正在测试一个使用异步的基于未来的API的actor。当未来完成时,actor使用管道模式向自己发送消息:import akka.pattern.pipe // ... //某处...
由于akka是一个用于构建actor模型的工具包,它是在JVM中运行的对象,因此创建后的actor对象的可靠性如何。保持让它崩溃的性质,多么可靠......
在并行处理项目列表时,是否有充分的理由增加Futures(vs并行集合)的复杂性? List(...)。par.foreach(x => longRunningAction(x))vs Future ....
Akka Java API - 如何扩展AbstractActor并使用Timers和Stash函数
基本上我想要一个使用Timers和Stash功能的Actor。在Scala中我们可以执行以下操作 - 使用带有Stash的Timer扩展AbstractActor在Java中我找到了两个类 - ...
Lagom Persistent Entities Actors是? /演员模特
我正在使用Lagom的persitent实体,并阅读Cassandra支持实现,保存读取端查询的状态。所以试图理解,持久性实体也是演员吗?意思是......
我正在计划我的物联网系统并将Akka.NET与奥尔良进行比较。一般来说,Orleans API更接近.NET标准,但我想知道还有其他方式与Grain通信吗?在......