AKKA Inbox收件箱
起因
得到ActorRef就可以给actor发送消息,但无法接收多回复,也不知道actor是否停止
Inbox收件箱出现就是解决这两个问题
示例
package akka.demo.actorimport akka.actor.* import java.time.Duration/**** created by tankx** 2019/9/12 与actor 通信模式ask或tell 无法支持接收多回复和观察其它actor的生命周期,所以inbox应用而生**/ fun main() {val system = ActorSystem.create("box-sys")val helloActor = system.actorOf(HelloActor.props("tom"))helloActor.tell("hi", ActorRef.noSender())val box = Inbox.create(system)box.send(helloActor, "how are you!")box.watch(helloActor)//监控actor 的生命周期,当actor stop, receive会接收到Terminated消息 helloActor.tell(PoisonPill.getInstance(), ActorRef.noSender());//毒死actorwhile (true) {try {val receiveObj = box.receive(Duration.ofSeconds(2))//可一直接收actor回的消息println("box receive:" + receiveObj)if (receiveObj is Terminated) {break}} catch (e: Exception) {println(e.message)}}Thread.sleep(2000)System.exit(1)}
转载于:https://www.cnblogs.com/tankaixiong/p/11511278.html
AKKA Inbox收件箱相关推荐
- php短信android,Android_Android短信操作常见协议和常用代码,content://sms/inbox 收件箱
conte - phpStudy...
content://sms/inbox 收件箱 content://sms/sent 已发送 content://sms/draft 草稿 content://sms/outbox 发件箱 conte ...
- javaMail获取收件箱邮件之javax.mail.FolderNotFoundException
情况一:通过pop3获取邮件 javax.mail.FolderNotFoundException: folder is not INBOXat com.sun.mail.pop3.POP3Folde ...
- java获取阿里邮箱收件箱、发件箱、草稿箱、已删除邮件、垃圾邮件
通过下面两句代码即可获得该邮箱下所有文件夹名称 Folder defaultFolder = store.getDefaultFolder(); Folder[] allFolder = defaul ...
- SSL方式获取邮箱收件箱
2019独角兽企业重金招聘Python工程师标准>>> QQ邮箱是强制要求使用SSL方式获取收件箱的: package emailUtil;import java.io.FileNo ...
- gmail收件箱标签设置_通过在Gmail中启用实验室功能来启动收件箱
gmail收件箱标签设置 We recently looked at how you can make it easier to manage multiple inboxes in Gmail us ...
- gmail收件箱标签设置_通过多个收件箱实验室有效管理您的Gmail
gmail收件箱标签设置 Most people have more than one email account and if you are using Gmail it's easy to ge ...
- android启用hdcp_如何在Android上启用优先收件箱(和设置仅重要通知)
android启用hdcp Yesterday Google released an updated Gmail application for Android 2.2 phones that sup ...
- 函数式编程基础_在收件箱中免费学习函数式编程的基础
函数式编程基础 by Preethi Kasireddy 通过Preethi Kasireddy 在收件箱中免费学习函数式编程的基础 (Learn the fundamentals of functi ...
- java 拉取收件箱邮件源码_邮件提醒系统:新邮件识别
最近在做邮件提醒抄送企业微信消息系统,就目前而言,无论是pop3还是imap都没有一个好的方法只接收新邮件,基本只能依靠收件箱列表message自行判断,下面给出几种思路并作对比. //收件箱 fol ...
最新文章
- 使用条件编译加密报文
- php查找函数所在文件
- sqlerror.java.1055,at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:1055)
- java 消息传递示例_java actor模型和消息传递简单示例
- 科技感的动态设计方法-1
- 2012-11-9到2012-12-8
- VIDEOIO ERROR: V4L: can't open camera by index 0
- Trie树kmpAC自动机后缀数组Manacher
- windows游戏编程_2020年适合程序员编程的笔记本电脑推荐
- 笨办法学python3_月底送书!入门Python都在学的“笨办法”,出进阶篇了!
- 为系统扩展而采取的一些措施——异步
- 我的世界药水合成表图Java_我的世界药水合成表图高清配方-我的世界药水合成表图一览...
- spring boot配置德鲁伊
- 日志解析LogParse启动参数配置
- MAC编译OpenJDK8:clang: error: unknown argument: ‘-fpch-deps‘
- JESD204B调试1
- ipad iphone开发_如何通过Chromecast观看iPhone / iPad视频?
- MySQL中update语句的深入分析
- 算术右移 java_Java 中 算术右移和逻辑右移有什么区别?
- 刘畊宏爆红,Keep巨亏,在线健身的冰与火
热门文章
- socket中使用心跳来检测连接是否断开[ZT]
- Markdown编辑器常用功能以及快捷键介绍
- linux网卡pci信息,在进行CGKlinux系统网络配置时,使用()命令可以查询出网卡的PCI编号与设备名的对应关系。...
- h264 aac mux flv
- 我的docker随笔24:docker产生coredump文件
- java任务追踪预警怎么写_分布式系统中如何优雅地追踪日志(原理篇)
- insert 数组_Java数组和集合的效率问题
- 【Flink】Flink 不支持部分 task 结束后进行 checkpoint
- 【Mac】Mac iTerm2 使用笔记 远程连接
- 【MySQL】MySQL Insert into select 大量锁表导致无法插入