Akka Actor - 等待一段时间等待消息,否则发送消息

2024-01-07

是否有可能制作一个Actor等待 X 秒来接收任何消息,如果收到消息,则照常处理它,否则将消息发送给其他人Actor(在构造函数中预先确定)?


有可能,看看Akka Actor“询问”和“等待”带有 TimeoutException https://stackoverflow.com/questions/10095927。但请记住,在 Actor 内部阻塞是一个非常糟糕的主意,因为在此期间 Actor 无法处理任何其他消息。此外,它还会阻塞一个 Akka 处理线程。

更好的方法是发送消息(即发即忘)并使用安排一些超时事件Akka调度器 http://doc.akka.io/docs/akka/snapshot/java/scheduler.html。当响应到达时,取消该事件或设置一些标志,以便在答复确实按时到达时不会触发该事件。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

Akka Actor - 等待一段时间等待消息,否则发送消息 的相关文章

  • 在 AKKA 中,对主管调用 shutdown 是否会停止其监督的所有参与者?

    假设我有一位主管连接了 2 位演员 当我的应用程序关闭时 我想优雅地关闭这些参与者 调用supervisor shutdown 是否会停止所有参与者 还是我仍然需要手动停止我的参与者 gracias 阻止主管 https github co
  • 导入 sbt 项目时出错,服务器访问错误,未解决的依赖项

    我正在尝试从 IntelliJ IDE 15 0 2 的 build sbt 中导入我的项目中的库 我不断收到未解决的依赖项错误 我尝试更新不同论坛的设置来解决该问题 但没有任何效果 我尝试过的几件事 使用代理设置更新 sbtconfig
  • 如何通过数据框中数组列的索引计算平均值

    我正在使用 Spark 2 2 我有一个关于合作的基本问题ArrayType 我没有找到可以使用的内置聚合函数 Given a DataFrame有一个柱子id和一列values of ArrayType 我们想按 id 分组 然后按索引计
  • 如何最好地处理 Future.filter 谓词不满足类型错误

    我喜欢 scala 的类型安全性 但我不断遇到的一个运行时错误是 Future filter predicate is not satisfied 我知道为什么会出现此错误 只是寻求有关如何最好地解决此错误并优雅地处理它的建议 或者也许我做
  • 标识符中下划线的 Scala 风格指南

    我已经接受了许多其他语言的观点 即下划线在标识符中具有与字母表一样多的自由度 因此 v and v 另外 尾随下划线是受到推崇的避免与保留关键字产生歧义 class case val abc 0
  • 在 scala 中混合类型参数和抽象类型

    我正在尝试使用的答案前面的问题 https stackoverflow com questions 2059601 circular type parameters definition in scala实现一个小型图形库 这个想法是将图视
  • 如何在 scala 中的二维数组上使用 contains 方法

    我有一个二维数组 我想检查二维数组内是否存在数组 我努力了 var arr Array Array 2 1 Array 4 3 var contain arr contains Array 4 3 println contain 这应该打印
  • 什么是 ZIO 错误通道以及如何了解要放入其中的内容?

    ZIO https zio dev https zio dev 是一个 scala 框架 其核心是ZIO R E A 数据结构及其站点给出了三个参数的以下信息 ZIO The ZIO R E A 数据类型具有三个类型参数 R 环境类型 该效
  • 具有定期更新的静态数据集的结构化流

    将流媒体与静态数据集合并是结构化流媒体的一个重要功能 但在每个批次中 数据集都会从数据源刷新 由于这些源并不总是那么动态 因此在指定的时间段 或批次数 内缓存静态数据集会提高性能 在指定的时间段 批次数之后 将从源重新加载数据集 否则从缓存
  • 在 Scala 中实现不区分大小写比较的字符串类

    我有许多带有不区分大小写的字段的类 我想将这些类的实例放入 HashMap 中 并通过不区分大小写的字符串查找它们 我不是每次想通过字符串索引实例或通过字符串查找实例时都使用 toLowerCase 而是尝试将此逻辑封装在 CaseInse
  • 视图和流有什么区别?

    在Scala 2 8集合框架中 有什么区别view and toStream 在视图中 每次访问元素时都会重新计算它们 在流中 元素在求值时会被保留 例如 val doubled List 1 2 3 4 5 6 7 8 9 10 view
  • 如何在 Scala mutable.Seq 上追加或前置

    Scala 有一些我不明白的地方collection mutable Seq http www scala lang org api current index html scala collection mutable Seq 它描述了所
  • 为什么这个 Clojure 程序在可变数组上运行如此慢?

    剧透警告 这是 代码降临 第六天的第一部分 我试图解决this http adventofcode com day 6Clojure 和 Scala 中的问题 Scala 程序在我的 Macbook Air 上运行良好 几秒钟内就完成了 然
  • Scala 中 Null/Nothing/Unit 的用法

    我刚刚读过 http oldfashionedsoftware com 2008 08 20 a post about nothing http oldfashionedsoftware com 2008 08 20 a post abou
  • 在 Scala 中创建 Java 对象

    我有一个 Java 类 Listings 我在 Java MapReduce 作业中使用它 如下所示 public void map Object key Text value Context context throws IOExcept
  • Scala 中的数字格式?

    我有一个从文件中读取的动态变化的输入 数字是Int or Double Scala 为什么要打印 0每次之后Double数字 Scala 有没有办法以与读取相同的方式打印它 Example var x Double 1 println x
  • 如何使用 Scala 2.11 和 sbt 0.13 运行 Cucumber?

    有人有使用 sbt 0 13 和 Scala 2 11 的 Cucumber 项目的示例吗 我需要两者吗cucumber scala 2 11和sbt cucumber plugin 0 8 0 该插件是最新的吗 插件现在去哪里了 哪里做
  • 为什么类型级计算需要 Aux 技术?

    我很确定我在这里遗漏了一些东西 因为我对 Shapeless 还很陌生并且我正在学习 但是 Aux 技术实际上是什么时候required 我看到它是用来暴露type通过将其提升为另一个 同伴 的签名来声明type定义 trait F A t
  • 如何将 Spark-sftp 等新库添加到我的 Pyspark 代码中?

    当我尝试在 Spark conf 中设置包依赖项 spark sftp 时 我收到 ClassNotFoundException 但当我使用以下命令执行脚本时它会起作用 Spark submit packages com springml
  • Scala Monad - 完整的示例[关闭]

    就目前情况而言 这个问题不太适合我们的问答形式 我们希望答案得到事实 参考资料或专业知识的支持 但这个问题可能会引发辩论 争论 民意调查或扩展讨论 如果您觉得这个问题可以改进并可能重新开放 访问帮助中心 help reopen questi

随机推荐

  • Snow Leopard 上的 Python,如何打开 >255 个套接字?

    考虑这段代码 import socket store scount 0 while True scount 1 print Creating socket d scount s socket socket socket AF INET so
  • 如何使用新的 Graph API 添加 Facebook 事件

    我正在尝试使用 Facebook api 创建一个事件 来自 django 应用程序 有人使用新的图形 API 创建了事件吗 检查这里 http developers facebook com docs api publishing htt
  • 禁用 git EOL 转换

    我试图让 git 不更改任何操作的任何行结尾 不幸的是 这样做似乎无关紧要 我已将其简化为以下测试用例 该测试用例具有尽可能多的不同机制来禁用此行为 从两台机器开始 Windows 计算机 A Linux 计算机 B 在两台机器上 git
  • 如何获取 app.config 中所有连接字符串的列表

    需要创建一个小型控制台应用程序 它需要两个参数 文件位置为app config file 密钥 我的问题是控制台应用程序需要读取connectionStrings并对其进行加密 然后将加密文本保存到配置文件中 我已经看过 但没有找到任何解决
  • 使用 PHP 调整图像大小

    我有一个不太确定的问题 我在其他地方看到过例子 但没有什么特别像我的情况 我想使用 PHP 调整图像大小 以便它们可读 而不仅仅是像使用 HTML 那样奇怪地拉伸 如果它们不是 250 像素宽或 160 像素高 我如何调整图片大小 使其成比
  • 在 Fortran 中传递不连续的数组部分

    我正在使用 intel fortran 编译器和 intel mkl 进行性能检查 我将一些数组部分传递给 Fortran 77 接口 调用如下 call dgemm transa transb sz s P P a Ts tilde sz
  • 是否可以用宏生成结构体?

    trait Print fn print self struct Printer p Box
  • 有没有办法在不使用 Firestore 的情况下直接将 Firebase Storage 显示到 RecyclerView 中?

    所以我目前正在使用FirestoreRecyclerAdapter通过Firestore数据库显示Firebase存储中的图像 即 Firebase Storage file url gt Firestore database url gt
  • c 中令人恼火的 select() 行为

    while xxx timeout tv sec TIMEOUT timeout tv usec 0 FD ZERO set FD SET sd set switch select FD SETSIZE set NULL NULL time
  • ImportError:没有名为twisted.persisted.styles的模块

    从 IDLE 中 我尝试使用新安装的 scrapy 1 0 3 运行脚本 我正在使用一个朋友提供的脚本 但在Windows上 我在一个Mac 从第一行导入 scrapy 开始 运行程序时出现此错误 ImportError No module
  • 我应该将 .idea/workspace.xml 添加到 gitignore 吗?

    当我尝试签出另一个分支时 出现以下错误 error Your local changes to the following files would be overwritten by checkout idea workspace xml
  • 删除指定字符之间的所有内容,包括多行

    我有一个内容如下的文件 this must go also this must go hello world and this one too 我想删除之间的所有内容 包括多行 所以我只剩下hello world 这仅删除一行上的部分 se
  • 使用 @Json.Encode 时隐藏模型中的字段

    在我的 ASP NET MVC4 应用程序中 我的模型定义如下 public class Employee BaseObject JsonIgnore public string FirstName get set JsonIgnore p
  • 预训练 Keras Xception 和 InceptionV3 模型

    我正在尝试使用 Keras 及其预构建的 ImageNet CNN 架构来解决一个简单的二元分类问题 对于 VGG16 我采取了以下方法 vgg16 model keras application vgg16 VGG16 Rebuild t
  • 减速器可以监听其他动作吗?

    目前 我正在创建操作 然后创建一个减速器来处理我的应用程序的不同部分 不同的域 我的应用程序列出了班级和学生 目前 我有一个应用程序已加载的操作 以便我知道何时删除加载微调器 我有针对班级和学生的操作 我的问题是 我发现我需要连续执行多个操
  • 我们可以在模拟器中测试Face ID吗?

    我们可以使用模拟器测试生物识别身份验证吗 iPhone X 模拟器显示 Face ID 注册菜单 但启用后我能做什么 它如何识别人脸进行身份验证 模拟器无法识别脸部 但允许您模拟匹配和不匹配的脸部 如果您已启用 Enrolled选项来自Fa
  • 响应式布局上的固定边距?

    简而言之 我正在开发带有列和行的响应式网页布局 每个列的宽度设置为与预定义的总宽度相关 列宽 总宽度 宽度 并且高度是固定的 现在的问题是 我希望内容宽度是流动的 但边距和填充是固定宽度 如下所示 代码看起来像这样 HTML div Lef
  • 如何在 IOS Xamarin.Forms 中将内容页面添加到段控件

    我在我的应用程序中使用了分段控制 我不知道如何像选项卡式页面一样将两个内容页面添加到Segment控件中 我已附上示例文件 请提出任何建议示例应用程序链接 https drive google com open id 1 lCg rQFFH
  • 无法使用 clang 和 libc++ 链接 libFuzzer.a

    我正在尝试链接在一起 libFuzzer a 用 clang 5 0 编译和 std c 11 我的模糊驱动程序 用 clang 5 0 编译并且 std c 11 stdlib libc libcurl 使用 clang 5 0 编译 具
  • Akka Actor - 等待一段时间等待消息,否则发送消息

    是否有可能制作一个Actor等待 X 秒来接收任何消息 如果收到消息 则照常处理它 否则将消息发送给其他人Actor 在构造函数中预先确定 有可能 看看Akka Actor 询问 和 等待 带有 TimeoutException https