1回答
我有3个不同类型的scala.concurrent.Future，需要在akka.dispatch.Futures.sequence中组合它们，以便在所有期货完成时得到通知，期货声明为：Future<Event> f3
我尝试将它们放在一个声明为Iterable<Future<Object>> futureIterable = new ArrayList<>();的I
浏览 17提问于2017-12-31得票数 0
1回答
就我所理解的Akka文档而言，Akka ActorSystem包含自己的线程池来执行参与者。我在一个也使用Java8期货的Java应用程序中使用Akka；后者由ForkJoinPool.commonPool()执行。因此，参与者和期货使用不同的池，这可能会击败隐藏在两个调度器中的某些假设(例如，Akka调度器可能假定期货在Akka池上运行)。这会
浏览 3提问于2015-04-08得票数 4
回答已采纳
我正在研究AKKA的Java Futures API，我看到了许多处理同一类型的多个期货的方法，但我没有看到任何处理不同类型的期货的方法。我猜我把事情搞得更复杂了。不管怎样，假设我们有两个不同的角色: actorA和actorB。它们基于不同的类，每个类返回不同的Future。然而，actor
浏览 2提问于2011-07-15得票数 0
回答已采纳
看过演示文稿后，我很好奇地想知道Akka实现的期货和代理带来了哪些额外的功能。
浏览 0提问于2013-05-02得票数 3
回答已采纳
2回答
我有许多完全异步的消耗工作，并且大致同时开始。我的意思是这样的： Future { startWork("work" + i) }但是我需要添加一些时间延迟，以便在不同的时间连续开始这些作品。
浏览 3提问于2013-04-15得票数 0
2回答
我试图理解何时使用，并发现比主要的Akka文档更有帮助。所以看起来阿克卡期货公司做的事情和完全一样。所以我问：
在参与者系统之外，Akka期货对Java期货有什么好处？什么时候使用每一个？在演员系统的背景下，为什么要使用Akka未来？不是所有参与者之间的消息都是异步的、并发的和非阻塞的吗？
浏览 5提问于2015-06-04得票数 16
回答已采纳
1回答
我目前正在将Akka经典应用程序移植到Akka类型机。我有以下几个组成部分：
JobDispatcher我在Akka中这样做的方式是让JobDispatcher做所有的要求，把期货放到一个期货列表中，然后把它转换成一个未来的列表，当这个集合的未来完
浏览 4提问于2022-04-04得票数 0
回答已采纳
我正在寻找Scala的Redis客户端实现。客户端应该是异步和非阻塞的，使用Akka期货.我发现了多少有用的东西：
但他们俩都有自己的问题。第一种是使用旧版本的Akka，这会导致编译问题，第二种使用scala.actors.Futures.future代替Akka期货。我看到了几个月前发生的一次谈话: groups.google.com/forum/#!msg
浏览 5提问于2013-01-31得票数 10
回答已采纳
有谁知道在哪里我可以找到一个经典的“聊天”应用程序的例子，使用Akka Futures和Scalatra 2.1？文档中的Futures示例有点琐碎，因为我对Akka完全陌生，对Scalatra也是相对较新的，所以我想从一个坚实的基础开始。我知道这可能很难，因为Scalatra 2.1还在正式开发中。
浏览 2提问于2012-03-01得票数 4
回答已采纳
我已经启动了一个在Scala上编写异步PostgreSQL驱动程序的项目，要成为异步的，我需要接受回调并使用将来，但是接受回调和未来会使代码变得很麻烦，因为您总是必须发送回调，即使它是无用的。，所以现在我对这个外部API的外观没有太多的想法。可能是这样的：但是，我不知道人们是如何在这方面组织API的。在其他项目中提供例
浏览 0提问于2012-03-10得票数 3
回答已采纳
2回答
如何将阿克卡演员与衰落结合起来
、、、、
我有一个包含akka、akka http和akka streams的应用程序，所以它不是rest或微服务是一个短暂的应用程序；它是rest的数据提取器，应用程序写到postgres db，它的工作原理--我对以这种方式将衰落和akka集成起来是否正确感到怀疑。flow注意：此外，我还使用其他
浏览 3提问于2021-02-24得票数 0
回答已采纳
1回答
我刚刚从Akka开始，我试图把一些杂乱无章的功能分割成更易于管理的部分，每个部分都由不同的演员来完成。
我的任务似乎完全适合这个演员模型。我有一个对象树，它们保存在数据库中。孩子们的财富取决于父母的财富。当计算节点上的财富时，这应该会在子节点上触发类似的计算。我希望收集所有更新的节点实例，并将它们同时保存在DB中。问题是，我不知道如何确保一个人收到了来自所有孩子的信息。一种简单的方
浏览 4提问于2012-10-09得票数 3
回答已采纳
1回答
scala中有没有内置的LRU内存缓存类，有大小限制和基于LRU/LFU的键回收？我已经尝试过https://doc.akka.io/docs/akka-http/current/common/caching.html，但是它看起来使用包装的期货有点复杂。 谢谢。
浏览 16提问于2021-11-02得票数 0
我将在Scala Futures 2.10.1中使用scala.concurrent包中的scala.concurrent和Promises。我应该用Akka代替吗？
浏览 1提问于2013-05-12得票数 12
回答已采纳
一开始我只想说我是阿克卡和期货公司的新手。所以，要温柔:)。
在返回ListenableFuture<Boolean>的类中有init方法。该方法应该在单独的线程中执行一些耗时的代码，并创建akka参与者，它正在侦听akka集群中的一些消息。init方法返回的未来应该在此参与者接收到特定消息并完成耗时的代码之后才能完成。如何使用来自番石榴的ListenableFuture实现这一目标？
浏览 4提问于2017-09-23得票数 0
回答已采纳
1回答
在关于的Akka1.1文档的示例中，我想知道如何以编程方式设置生成的未来的超时。我知道我可以在akka.conf中调整全局超时，但我只想对这段代码进行适当的调整。(a + b)在这个例子中，akka总共创造了四个期货，我说得对吗？发送给actor1、2和3的每条消息一条
浏览 0提问于2011-07-13得票数 6
回答已采纳
在普通Scala和flatMap中不同之处在于，flatMap将返回数据的迭代值，这些数据被展平成一个列表。然而，在Akka文档中，map和flatMap似乎做了一些不同的事情？它说：“通常情况下，这会运行得很好，因为这意味着运行一个快速函数的开销很小。如果函数可能需要大量的时间来处理，那么并发处理可能会更好，为此，我们使用flatMap:” "Hello" + "World"
val
浏览 3提问于2011-07-14得票数 39
回答已采纳
1回答
我认为来自的修改版的将运行良好，但我在连接这些部分时遇到了困难。考虑到source: Source[String, Unit]和ctx: RequestContext，我认为修改后的StreamingActor应该与actorRefFactory.actorOf(fromSource为供参考，以上要点：import akka.util.ByteStringimport
浏览 1提问于2015-11-05得票数 0
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
