Scala Future回调未打印结果问题求助

我明白你排查了好几个小时的困扰，这个问题其实是Scala Future初学者很容易踩的坑，核心原因和JVM线程的生命周期有关，咱们一步步来解决：

问题根源 #

Scala的Future默认使用守护线程池来执行异步任务（由ExecutionContext.Implicits.global提供）。当你的主线程（比如main方法或者脚本的主线程）执行完创建Future和注册回调的代码后，会直接退出，JVM会立刻终止所有守护线程——这时候Future的任务可能还没来得及执行，或者回调还没触发，自然就看不到打印的"50"了。

另外还要确认你是否导入了必要的依赖包：创建Future需要隐式的ExecutionContext，如果没导入scala.concurrent.ExecutionContext.Implicits.global，代码甚至无法编译通过（Scala REPL可能会自动导入，但独立程序必须显式导入）。

修正后的代码示例 #

下面是调整后的完整代码，解决了主线程提前退出的问题：

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

object DangerousAndSlowService {
  def queryNextNumber: Long = 50
}

object Main extends App {
  val number1F = Future {
    DangerousAndSlowService.queryNextNumber
  }

  number1F.onComplete {
    case Success(value) => println(s"Got the callback, meaning = $value")
    case Failure(exception) => exception.printStackTrace()
  }

  // 让主线程等待Future完成，最多等待5秒（可按需调整时长）
  Await.ready(number1F, 5.seconds)
}

关键调整说明 #

1. 导入必要的包：

   • ExecutionContext.Implicits.global：提供默认的线程池来调度Future的异步任务。
   • Await和duration._：用于让主线程等待Future完成，避免提前退出。

2. 使用Await.ready：
   这个方法会阻塞主线程，直到Future完成（不管是成功还是失败），或者等待超时。这样就能确保回调函数有足够的时间执行并打印输出。

其他可选方案 #

如果你不想用Await（比如在非阻塞场景下），也可以让主线程主动睡眠一段时间（比如Thread.sleep(1000)），但这种方式很不可靠——你无法预知Future任务到底需要多久完成，所以更推荐用Await的方式。

如果是在Scala REPL中运行代码，其实不需要额外等待，因为REPL的主线程会一直保持运行状态，只要导入了必要的包，回调就能正常触发打印。

内容的提问来源于stack exchange，提问作者Che-Hao Kang