Scala 中多个 Future 的奇怪情况

Question

Scala 中那些与 Future 相关的类和特征之间有什么联系？为什么它们分布在不同的包中？

我发现了这些：

abstract class scala.actors.Future
object         scala.actors.Futures
trait/object   scala.collection.parallel.FutureThreadPoolTasks
trait          scala.concurrent.FutureTaskRunner
trait          scala.parallel.Future    (the package consists of only this file...)

它们是否有显着不同的事情，或者是否有其他原因导致它们无法合并？

有没有一个很好的例子来说明何时使用其中一种或另一种？

编辑：奖励解释每个类/特征/对象的作用以及它们如何证明其存在的合理性/它们如何有用。

Answer 1

scala.actors._

abstract class Future

首先，让我们看看文档是怎么说的：

arity 0 的函数，返回 T 类型的值，应用该值时，会阻止当前参与者 (Actor.self)，直到未来的值可用为止。

这基本上就是全部了。如果您从另一个 Actor 之外的任何地方与 Actor 进行通信（它可以使用 sender 引用简单地通过另一条消息接收对消息的异步回复）并且您需要对已发送消息的回复，那么您可以有两种选择：

• 发送一条阻塞消息，等待 Actor 完成计算结果
• 使用返回 Future 的方法发送一条消息，并且仅当您确实需要相关值时才阻塞该 Future（到那时该值可能已经被 因此，

Future 是一个尚未存在但可能在不久的将来会存在的值的占位符。下面的内容也很有趣：

可以在不阻塞的情况下查询 future 以查明其值是否已经可用 [使用“isSet”]。

这允许您做任何您想做的事情，直到计算/获取您需要的值，并且您可以定期检查该值是否可用。

当深入研究 Scala 库源代码时，我发现 Futures 实际上只是参与者。 Future本身是一个抽象类，由私有类FutureActor扩展。最后一个类是实际实现 Future 功能的类。

object Futures

到目前为止，object Futures 并不那么有趣，因为它仅仅是“操作 futures 的方法”的容器，方便的工厂方法 future 异步评估传递的块，返回代表结果的 future。一个小例子是这样的：

import scala.actors.Futures
val f = Futures.future {
    println("Start: inside block")
    val s = System.currentTimeMillis
    while(System.currentTimeMillis < (s + 1000)) {
        // Simulate computation
    }
    println("Start: end of block")
    42
}
println("After future")
println(f())
println("The end")

这应该会导致类似的结果

Start: inside block
After future
Start: end of block
42
The end

这表明 future 调用不会阻止以下代码，直到您实际尝试检索 future 的值（请注意，输出是非确定性也可能出现在开头。输出）。

scala.collection.parallel

这个包是 Scala 2.9.x 中的新包，它为我们最喜​​欢的一些集合实现了并行对应项。这些都以 Par 开头：

• ParIterable
• ParSeq
• ParSet
• ParMap

您可能已经知道或猜到，这些集合以并行方式实现所有可能的操作，而您无需担心。一个小演示：

(1 to 10).par.map { b => print(b + " "); b * b }
3 1 6 2 7 4 5 9 10 8
    # => (1, 4, 9, 16, 25, 36, 49, 64, 81, 100)

结果始终是相同的，但处理元素的顺序又是不确定的。此外，如果您使用的是多核系统，对于较大的集合，您可能会体验到良好的性能提升。

trait FutureThreadPoolTask​​s

FutureThreadPoolTask​​s 特征扩展了 Tasks 特征，所以让我们先看一下这个特征。该特征上方的评论说：

声明并行集合使用的任务执行功能的特征。

从其他源注释和 Tasks 特征中找到的方法来看，任务表示需要计算的工作单元。根据问题是否可以进一步划分，以及如果有更多可用资源，任务可以通过创建更多任务来进一步拆分任务。

现在，FutureThreadPoolTask​​s 特性本身只是一种计算任务的方法，它使用 java.util.concurrent.Future 类进行同步，也就是说，它确实不要使用scala.actors.Future！从源头看：

基于 Java 线程池 API 和使用 future 进行同步的任务对象实现。

object FutureThreadPoolTask​​s

再次不是很引人注目，只是一个伴随对象，其中包含 FutureThreadPoolTask​​s 特征使用的一些（实际上只有三个）实用程序方法。

scala.concurrent

关于这些类的文档非常糟糕，而且显然很少有（我没有找到一个）示例来演示这些类的用法。我一定会尽力收集更多有关这些的信息，并尽快扩展本节！

scala.parallel

trait Future

这似乎是一个“正在进行中的工作”，因为 scala.parallel 包仅包含此特征。据我所知，这将与不使用 Actors 的 Future 实现相关，但这只是一个猜测。该特征的签名如下，

trait Future[@specialized +R] extends (() => R)

我什至不打算尝试解释 @specialized 注释 或 变体（通用 R 类型之前的 +），但这个特征的基本思想是，Future 是一个函数，在执行时返回值（如果尚未计算，则必须阻塞）。

此外，特征本身内部只有两个方法，apply 和 isDone。我的猜测是，isDone 就像 scala.actors.Future.isSet 一样，应该是一个非阻塞调用，以查看值是否已计算出来，并且应该使用 apply 方法来实际检索该值。

Answer 2

下面是一个简单的解释。 （部分内容是从 scala 文档复制的）。如果您有不明白的地方，请告诉我，我会尽力更具体，并给您一个具体的例子。

抽象类scala.actors.Future -- 你熟悉java.util.concorrent.Future？ scala.actors.Future 基本上表示异步计算的结果，但对于 actors 来说。

scala.actors.Futures -- 一个对象 (~singleton)，包含四个用于处理 scala.actors.Future 的实用方法。

scala.parallel.Future --（这对我来说是新的，但它包含非常基本的操作（apply 和 isDone））它是一个没有参数的函数，如果与以下内容相关的并行计算将阻止调用者功能未完成。 （函数？提示：extends（））

scala .collection.parallel.FutureThreadPoolTask​​s -- 来自 scala 文档：“基于 Java 线程池 API 和使用 future 进行同步的任务对象的实现。”够了吗？ :)

scala.concurrent.FutureTaskRunner -- 你熟悉执行器？ ExecutorScheduler 是 scala 标准库中的一个（三分之一）具体实现。 executeFromActor 是更有趣的方法之一，应该会提示您何时需要使用此方法