如何使用AKKA实现下面的流程?

发布于 2021-11-25 14:02:30 字数 777 浏览 766 评论 5

上图所示的过程中,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()) {
            }



不知道使用actor是怎么实现这种的功能?或者actor不适合这一种?

2.akka 中的 dispatcher 与route 有什么 区别么?分别适合什么样的场景? 



如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(5

画骨成沙 2021-12-02 03:58:17

引用来自“羊八井”的评论

这个实现很简单的,看我写的介绍:

  1. http://my.oschina.net/yangbajing/blog/538282
  2. http://my.oschina.net/yangbajing/blog/535652
你曾走过我的故事 2021-12-02 02:28:31

引用来自“Ambitor”的评论

楼主 这不是 Map Reduce 或者说Forkjoin 的原理么~~

躲猫猫 2021-12-01 23:55:55

楼主 这不是 Map Reduce 或者说Forkjoin 的原理么~~

温柔少女心 2021-11-30 17:44:33

去看看akka的

Ask: Send-And-Receive-Future

下面的连接里找这个关键词:

http://doc.akka.io/docs/akka/2.4.0/java/untyped-actors.html

瑾兮 2021-11-30 05:44:47

这个实现很简单的,看我写的介绍:

  1. http://my.oschina.net/yangbajing/blog/538282
  2. http://my.oschina.net/yangbajing/blog/535652
~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文