为什么 Future[Set[Unit]] 不被接受为 Future[Unit]？

Question

使用期货时的一个常见问题是，当您期望Future[Unit] 时，即使Future[Future[Unit]] 也会被接受（例如，请参阅Why Shouldn’t You Use Future[Unit] as a Return Type in a Scala Program）。

我最近很惊讶Future.sequence(setOfFutures)在这种情况下不被接受：

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

val set = Set(Future(()))

def fuu: Future[Unit] = {
  Future.sequence(set)
}

使用 Scala 2.12.13 我得到错误：

类型不匹配；

找到：scala.concurrent.Future[scala.collection.immutable.Set[Unit]]

使用 Scala 2.13 我得到：

无法基于 scala.collection.immutable.Set[scala.concurrent.Future[Unit]] 类型的集合构造具有 Unit 类型元素的 Unit 类型集合。

当我将函数的主体更改为：

  val s = Future.sequence(set)
  s

我得到了和以前一样的错误。

为什么Future[Future[Unit]] 被接受为Future[Unit] 而Future[Set[Unit]] 或Future[List[Unit]] 不被接受？

Answer 1

考虑 Scala 2.13 中 Future.sequence 的签名

def sequence[A, CC[X] <: IterableOnce[X], To](in: CC[Future[A]])(
  implicit 
  bf: BuildFrom[CC[Future[A]], A, To], 
  executor: ExecutionContext
): Future[To]

给定

val set = Set(Future(()))
def fuu: Future[Unit] = Future.sequence(set)

然后推理将像这样分配sequence 的类型参数

To = Unit
A = Unit
CC = Set

例如考虑fuu 的返回类型Future[Unit] = Future[To]。因此我们有

def fuu: Future[Unit] = Future.sequence[Unit, Set, Unit](set)

所以编译器需要隐式分配bf参数

scala> implicitly[BuildFrom[Set[Future[Unit]], Unit, Unit]]
                 ^
       error: Cannot construct a collection of type Unit with elements of type Unit based on a collection of type Set[scala.concurrent.Future[Unit]].

现在考虑 Future.sequence 的 Scala 2.12 签名

def sequence[A, M[X] <: TraversableOnce[X]](in: M[Future[A]])(
  implicit 
  cbf: CanBuildFrom[M[Future[A]],A,M[A]],
  executor: ExecutionContext
): Future[M[A]]

给定

val set = Set(Future(()))
def fuu: Future[Unit] = Future.sequence(set)

推理变成

A = Unit
M = Set

所以我们有

def fuu: Future[Unit] = Future.sequence[Unit, Set](set)

编译器可以成功隐式分配cbf参数的地方

scala>  implicitly[CanBuildFrom[Set[Future[Unit]],Unit,Set[Unit]]]
res4: scala.collection.generic.CanBuildFrom[Set[scala.concurrent.Future[Unit]],Unit,Set[Unit]] = scala.collection.generic.GenSetFactory$$anon$1@1bff70a6

因此我们在 2.12 中实际上有以下情况

scala> def fuu: Future[Unit] = Future.sequence(set) : Future[Set[Unit]]
<console>:25: error: type mismatch;
 found   : scala.concurrent.Future[Set[Unit]]
 required: scala.concurrent.Future[Unit]
def fuu: Future[Unit] = Future.sequence(set) : Future[Set[Unit]]

这应该解释了两个 Scala 版本之间的两个编译器错误消息之间的差异与丢弃值无关，而是与推理如何分配相应的类型有关。