如何使用AKKA实现下面的流程?
上图所示的过程中,Do someting 执行的时间长短未知,可能是1分钟,也可能是10分钟,等所有执行完成以后,会有一个Call back,之前我使用Thread的时候,是如下实现的:
ExecutorService executor = Executors.newFixedThreadPool(100); for (AnalyzerResultEntity entity : resultList) { executor.execute(new AnalyzerResultThread(entity, analyzeResultDBColl)); } executor.shutdown(); while (!executor.isTerminated()) { }
2.akka 中的 dispatcher 与route 有什么 区别么?分别适合什么样的场景?
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(5)
引用来自“羊八井”的评论
这个实现很简单的,看我写的介绍:
引用来自“Ambitor”的评论
楼主 这不是 Map Reduce 或者说Forkjoin 的原理么~~
楼主 这不是 Map Reduce 或者说Forkjoin 的原理么~~
去看看akka的
Ask: Send-And-Receive-Future
下面的连接里找这个关键词:
http://doc.akka.io/docs/akka/2.4.0/java/untyped-actors.html
这个实现很简单的,看我写的介绍: