选择Actor
在一个ActorSystem中可能存在大量的Actor,如何有效对其进行批量管理和通信?框架提供了ActorSelection类,用来批量消息发送。示例代码如下:
消息收件箱Inbox
Akka框架提供了收件箱组件Inbox,可以方便的对Actor进行消息发送和接收,也方便了程序和Actor之间的交互。
示例中Worker会根据收到的消息打印自己的工作状态,当收到CLOSE消息时,会关闭自己结束运行。
main方法及运行结果--参考文献《实战Java高并发程序设计》
选择Actor
在一个ActorSystem中可能存在大量的Actor,如何有效对其进行批量管理和通信?框架提供了ActorSelection类,用来批量消息发送。示例代码如下:
消息收件箱Inbox
Akka框架提供了收件箱组件Inbox,可以方便的对Actor进行消息发送和接收,也方便了程序和Actor之间的交互。
示例中Worker会根据收到的消息打印自己的工作状态,当收到CLOSE消息时,会关闭自己结束运行。
main方法及运行结果--参考文献《实战Java高并发程序设计》
本文标题:Akka框架之选择Actor和消息收件箱Inbox
本文链接:https://www.haomeiwen.com/subject/cgjshctx.html
网友评论