斯卡拉检查，如果未来[序列[字符串]的isEmpty

Question

我想检查是否有未来[序列[字符串]是空的，我使用

if(!Future.sequence(sortSeq).isEmpty){ 
//doSomething 
} 

但将我错误？

Answer 1

我想sortSeq的类型是Future[Seq[String]]，所以你不需要Future.sequence。

你必须等待你Future的结果，然后检查，如果结果为空：

import scala.concurrent.duration._ 
if(!Await.result(sortSeq.map{_.isEmpty}, 5.seconds){ 
    //doSomething 
} 

如果你可以在不同的线程执行doSomething你可以试试这个：

val someRusultFuture = sortSeq.map{ rs => 
    if(!rs.isEmpty){ 
    //doSomething 
    } 
} 

但您必须等待someRusultFuture的结果。

证明它的工作原理：

scala> import concurrent.{Future, Await} 
import concurrent.{Future, Await} 

scala> import scala.concurrent.duration._ 
import scala.concurrent.duration._ 

scala> val sortSeq = Future{ Thread.sleep(10000); Seq("a") } 
sortSeq: scala.concurrent.Future[Seq[String]] = scala.concurrent.impl.Promise$DefaultPromise@3592f7c6 

scala> Await.result(sortSeq.map{_.isEmpty}, 11.seconds) 
res1: Boolean = false 

Answer 2

Future.sequence方法用于一个TraversableOnce[Future[A]]转变为Future[TraversableOnce[A]]。

我想你可以忘记Seq是否为空或不使用的Future

val s = Future[Seq[String]](Seq("s", "e", "q")) 
    val p = s.map(s => s.foreach(println)) 

的map功能这样做是因为，在后台隐式执行空管检查与Seq只是工作。在下面的例子中，当Seq为空时，不会打印任何内容。

scala> val s = Future[Seq[String]](Seq.empty) 
s: scala.concurrent.Future[Seq[String]] = Future(<not completed>) 

scala> val p = s.map(s => s.foreach(println)) 
p: scala.concurrent.Future[Unit] = Future(<not completed>) 

如果你真的想执行空的检查，可以也使用withFilter。

对于非空Seq

scala> val s = Future[Seq[String]](Seq("s", "e", "q")) 
s: scala.concurrent.Future[Seq[String]] = Future(Success(List(s, e, q))) 

scala> val p = s.withFilter(_.nonEmpty).map(s => s.foreach(println)) 
p: scala.concurrent.Future[Unit] = Future(<not completed>) 

s 
e 
q 

随着空Seq

scala> val s = Future[Seq[String]](Seq.empty) 
s: scala.concurrent.Future[Seq[String]] = Future(Success(List())) 

scala> val p = s.withFilter(_.nonEmpty).map(s => s.foreach(println)) 
p: scala.concurrent.Future[Unit] = Future(<not completed>) 

你也可以做的空白支票作为上述答复中提到

val someRusultFuture = sortSeq.map{ rs => 
    if(!rs.isEmpty){ 
    //doSomething 
    } 
} 

希望这有助于。