val xyz =List(Future(1),Future(2),Future(3),Future(4),Future(5))我得到的错误是found : Intxyz.reduceLeft((a,b) => Await.result(a,
浏览 4提问于2019-11-27得票数 0
回答已采纳
我正在研究Scala期货，无意中发现了下面的代码： def await[T](f: Future[T]) = Await.result(f,但是在上面的例子中，正如我所理解的，在reduceLeft值x的第一次传递中，10被应用于函数a，结果被应用到使用flatMap的函数b中，后者最终返回Future[Int] (例如，我称之为result在下一次使用reduceLeft时，必须使用result和函数h，但我
浏览 3提问于2020-06-08得票数 1
回答已采纳
reduceLeft和reduceRight在Scala中有什么区别？val list = List(1, 0, 0, 1, 1, 1)
val sum2 = list reduceRight{_ + _}
在我的代码片段sum1 = sum2 = 4中，所以顺序在这里并不重要。
浏览 1提问于2015-09-23得票数 3
回答已采纳
我在Scala中有一个id列表，对于每个id，我将启动一个将来来执行如下所示的数据库操作： Future(get(id))我注意到，期货只有在完成了对列表的遍历之后才会执行(列表非常大)。我如何在不等待遍历完成的情况下，尽可能(基于可用线程)
浏览 1提问于2014-05-14得票数 0
回答已采纳
1回答
Play是异步或非阻塞框架
、、、、
我读过几个教程，到处都提到play是“非阻塞”的。我搞不懂所谓的非阻塞是指异步I/O还是非阻塞I/O。另外，异步是否意味着主线程可以产生一个新线程，并将其工作委托给它并运行下一条语句？(为此，我们需要使用akka)
浏览 2提问于2017-05-23得票数 0
1回答
我有以下scala代码：val inMsgs = gates.map(g => g.getEndGate.getMessage())这是否与C++中的相同(假设我们知道使用的类型和底层C++容器是一个向量getMessage(); mar
浏览 3提问于2014-02-23得票数 0
回答已采纳
1回答
以下函数计算Scala中两个2D点之间的欧几里德距离： sqrt(pow(pt1(0)-pt2(0), 2)+pow(pt1(1)-pt2(1), 2))def perimeter(arr: ListBuffer[List[Double]]): Double =
arr.r
浏览 2提问于2018-05-22得票数 2
回答已采纳
我对spark和scala语言非常陌生，我希望将列表中的所有RDDs合并如下(List<RDD> to RDD)：at scala.collection.TraversableOnce$$anonfun$reduceLeft$1.apply(TraversableOnce.
浏览 6提问于2015-05-25得票数 8
回答已采纳
1回答
在Scala2.10中，什么是正确的方法来编写一个返回将来的函数，当列表中的所有期货都完成时它就完成了？经过研究和实验，我在Scala工作表中开发了下面的代码：import scala.concurrent.ExecutionContext.Implicits.globalimport scala.concurrent.duration._
import
浏览 3提问于2014-04-30得票数 12
回答已采纳
我已经启动了一个在Scala上编写异步PostgreSQL驱动程序的项目，要成为异步的，我需要接受回调并使用将来，但是接受回调和未来会使代码变得很麻烦，因为您总是必须发送回调，即使它是无用的。query => }.get( 5, TimeUnit.SECONDS ).rowsAffected === 1发送空回调非常可怕，但我无法找到一种方法使其成为可选的或类似的东西，所以现在我对这个外部可能是这样的：
handler.sendQuery( this.create ).addListener { query => println
浏览 0提问于2012-03-10得票数 3
回答已采纳
下面是Scala的特性的reduceLeft方法的源代码。var acc: B = 0.asInstanceOf[B]这一行发生了什么变化
浏览 1提问于2011-12-12得票数 27
回答已采纳
2回答
我知道，我可以使用回调，flatMap组合或一个理解链期货.当一个未来完成后，另一个未来就开始了，依此类推。
是否有一种方法可以链接存储在Scala (例如List)中的任意数量期货的执行？我试图在这个未来列表中调用Future.sequence，但它们一起启动，它们是并发执行的(而不是按顺序执行)。
浏览 7提问于2016-04-27得票数 0
回答已采纳
在下面的方法中，我希望通过对列表执行reduceLeft来返回地图。我的问题是，有时列表是空的，所以我不确定正确的处理方法： val iter = new QueryIterator<- iter) yield (Map(hcol.getValue() -> li
浏览 0提问于2012-03-10得票数 1
回答已采纳
2回答
我有许多完全异步的消耗工作，并且大致同时开始。我的意思是这样的： Future { startWork("work" + i) }但是我需要添加一些时间延迟，以便在不同的时间连续开始这些作品。例如，如果(time lag =1秒) => i-work在i秒后开始。怎么能简单地做到这一点呢？
浏览 3提问于2013-04-15得票数 0
期货非常方便，但在实践中，您可能需要对它们的执行进行一些保证。例如，考虑以下内容： Thread.sleep(time * 1000)但是，如果期货执行的函数不返回，我们就不想永远挂起。因此，我们使用awaitAll()在期货上设置超时。但是，如果您运行代码，您会看到5秒计时器过期，但10秒的未来继续运行，并在稍后返回。那么，如何在超
浏览 1提问于2009-08-07得票数 6
问题是，假设有一个函数xyz()，它有一个返回类型的Future[Some[Boolean]]，现在我想要的是，每当这个布尔值为真时，我想要触发一个函数abc()，我不知道如何在scala中对它进行重构我试过的是ans.map((itr)=>{ Some(true)=> abc()})
我也可能完全错了，我对期货也不太了解，请推荐任何容易理解的期货文档，也请解
浏览 6提问于2022-01-15得票数 0
我正在寻找一种方法，将任意长度的未来列表转换为未来列表。，但有一个问题……我得到的列表中通常有大约10-20个期货，其中一个期货失败的情况并不少见(他们正在发出外部web服务请求)。例如，执行以下操作不起作用import scala.concurrent.ExecutionContext.Implicits.global
importscala.util.Succ
浏览 85提问于2014-01-02得票数 121
回答已采纳
将get方法与Future类分离(我希望它驻留在这个类中)并迫使编码器必须知道这个名为Await的外部两种方法类，有什么特别的优势吗？
浏览 5提问于2016-07-01得票数 11
回答已采纳
所以我像这样试了试reduceLeft。p.map { case (k,v) => if (k == 1) v }.toList.reduceLeft((a,b) => if (a.length > b.length) a else b )我需要把它转换成一个字符串列表吗？
浏览 4提问于2017-07-19得票数 1
基本上，我试图在Odersky的书(Scala编程)中运行示例3.11。我正在使用Intellij。在运行代码时，执行了“While”分支。args.length > 0){ val longestLine = lines.reduceLeft我尝试了几个选项，但没有找到正确传递args的方法，以便在"if“分支中执行代码。解决这个问题有两个方向:
浏览 1提问于2018-01-21得票数 1
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
