Scala Future monod 中的 onComplete 方法

Question

我正在学习 Scala 中的 Future 并拥有以下代码 sn-p。我正在根据名称中的第一个字母生成随机标记。 对于以下场景，我希望通过onComplete 方法打印一个列表。但它不打印任何东西。

def randomMark(name:String) = name(0) match {
  case 'R'|'A'|'J'|'S' => Thread.sleep(500); 99
  case  _              => Thread.sleep(500); 80
}

import scala.concurrent._
import concurrent.ExecutionContext.Implicits.global

val returns = Future sequence List( Future(randomMark("Rob")), Future(randomMark("Andy")), Future(randomMark("George")) )
    
Thread.sleep(550)

returns onComplete { e => { val y1 = e.getOrElse("Error"); println(y1) } }    
//This println statement does not execute. I expect a list List(99,99,80) to be printed

有人可以帮我理解为什么我为onComplete 方法提供的功能文字不执行吗？

谢谢！

Answer 1

很可能是因为您需要等待结果，因为onComplete 是一个异步操作。

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

def randomMark(name:String) = name(0) match {
  case 'R'|'A'|'J'|'S' => Thread.sleep(500); 99
  case  _              => Thread.sleep(500); 80
}

import scala.concurrent._
import concurrent.ExecutionContext.Implicits.global

val returns = Future sequence List( Future(randomMark("Rob")), Future(randomMark("Andy")), Future(randomMark("George")) )
    
Thread.sleep(550)

returns onComplete { e => { val y1 = e.getOrElse("Error"); println(y1) } }   
println("Waiting futures to be completed")
Await.ready(returns, 5.seconds)
println("Futures to be completed")

打印出来了：

Waiting futures to be completed
List(99, 99, 80)
Futures to be completed

斯卡蒂：https://scastie.scala-lang.org/SWv18p8RTtuo7nMNHNHMoQ

Answer 2

由于回调是异步执行的，因此您需要在程序退出之前等待回调完成。在这种情况下，如果你想等待一个 onComplete 回调，你需要以某种方式发出它的完成信号。在以下示例中，我使用了 Promise：

def randomMark(name:String) = name(0) match {
  case 'R'|'A'|'J'|'S' => Thread.sleep(500); 99
  case  _              => Thread.sleep(500); 80
}

import scala.concurrent._
import scala.concurrent.duration._
import ExecutionContext.Implicits.global

val returns = Future sequence List( Future(randomMark("Rob")), Future(randomMark("Andy")), Future(randomMark("George")) )
val returns: scala.concurrent.Future[List[Int]] = Future(<not completed>)

val p = Promise[Unit]()

returns onComplete { e => { val y1 = e.getOrElse("Error"); println(y1); p.success(()) } }

Await.ready(p.future, 5.seconds)

但是，您可以改用 andThen，如下所示：

def randomMark(name:String) = name(0) match {
  case 'R'|'A'|'J'|'S' => Thread.sleep(500); 99
  case  _              => Thread.sleep(500); 80
}

import scala.concurrent._
import scala.concurrent.duration._
import ExecutionContext.Implicits.global

val returns = 
  Future sequence List( Future(randomMark("Rob")), Future(randomMark("Andy")), Future(randomMark("George")) ) andThen
  { case e => { val y1 = e.getOrElse("Error"); println(y1) } }

Await.ready(returns, 5.seconds)