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