第一个for回调几乎每次都打印未来列表，第二个onComplete回调很少返回成功（从不失败）

Question

我在看一些未来的例子。我有一个从方法中获取列表的未来。我调用了两种不同类型的回调，Foreach回调和onComplete回调，只是为了尝试一下。

• Foreach回调几乎每次都返回列表。
• 即使For回调返回了列表，on完成回调也很少返回SUCCESS。
• on完成回调永远不会返回FAILURE。

有人能给我解释一下发生了什么吗？

我知道回调是并发执行的，没有顺序。但是如果Future正在将列表返回给Foreach，而onComplete回调已经在Foreach和Future之前执行，并且它试图从一个不成功的Future获取列表，那么onComplete回调不应该返回失败吗？

import scala.concurrent.Future
import scala.concurrent.ExecutionContext.Implicits.global
import scala.util.{Failure, Success}

object FuturesExampleObj extends App {

  println("Using Future to retrieve list\n")
  val l: Future[List[String]] = Future {
    getList()
  }

  println("FOR CALLBACK --------------------\n")

  l foreach {
    items =>
      for(item <- items) println(s"foreach item : $item")
      println("\n")
  }

  println("onComplete CALLBACK --------------------\n")

  l onComplete {
    case Success(i) => println(s"SUCCESS : $i")
    case Failure(i) => println(s"FAILURE : $i")
  }

  def getList(): List[String] ={
    val list = ("a" :: "b" :: "c" :: "d" :: "e":: Nil)
    list
  }
}

结果示例1（通用）

Using Future to retrieve list

FOR CALLBACK --------------------

onComplete CALLBACK --------------------

foreach item : a
foreach item : b
foreach item : c
foreach item : d
foreach item : e



Process finished with exit code 0

结果示例2（不常见）

Using Future to retrieve list

FOR CALLBACK --------------------

onComplete CALLBACK --------------------


Process finished with exit code 0

结果示例3(非常罕见)

基本上，onComplete 从不返回成功或失败。有时，很少会返回“SUCCESS：”列表。

Answer 1

原因是应用程序线程在“未来”完成之前完成。

只需添加Await.ready（l，Duration.Inf）。value.get。

这样做只是为了测试！

Answer 2

这是因为你必须明确地阻止未来。在您的情况下，主线程在＜code＞onComplete＜/code＞完成之前终止，有时在＜code>l foreach..完成之前终止。

请补充：

import scala.concurrent.{Await, Future}
import scala.concurrent.duration._

val listF = l foreach {
  items =>
    for(item <- items) println(s"foreach item : $item")
    println("\n")
}

Await.result(listF, 5 seconds)

这样，您将等待这个未来的完成。

如果您想等待on完成，您需要使用Thread.sleep（在on完成之后添加它，例如：

l onComplete {
   case Success(i) => println(s"SUCCESS : $i")
   case Failure(i) => println(s"FAILURE : $i")
}

Thread.sleep(3000)

onComplete 在 ExecuteContext 中的某个线程上运行，而 Await 在当前线程上运行，并阻止它，直到它完成或超过指定的超时。因此，onComplete 是非阻塞的，而 Await 是阻塞的。

使用< code>onComplete时，我们不会阻止来自< code>Future的结果，而是会收到一个< code >成功或< code >失败的回调。

< code>Thread.sleep()正在阻塞我们的主线程，以便我们可以看到未来的异步结果。

请注意，您不应该在生产代码中使用< code>Await.result，它用于测试未来的输出。此外，您肯定不会使用< code>Thread.sleep(),而是对未来返回的结果做出“反应”。

通常，您将有一些REST API调用或其他服务运行并等待将来完成。