懒惰提交的函数

Question

我在学习 Paul Chiusano 和 Runar Bjanarson 所著的“Scala 中的函数式编程”一书（第 7 章 - 纯函数式并行）时遇到了这个函数定义：

 def fork[A](a: => Par[A]): Par[A] = 
    es => es.submit(new Callable[A] {
      def call = a(es).get
    })

Par[A] 是 type Par[A] = ExecutorService => Future[A] 和 ExecutorService 和 Future 来自 java.util.concurrent 库。 Here 是 Github 上的完整代码。有关java.util.concurrent 文档，请参阅here。

我的问题是提供一个函数作为惰性参数意味着什么？特别是，我可以理解延迟提供计算意味着什么，但我无法理解它在函数的情况下意味着什么？

Answer 1

提供一个函数作为惰性参数

对于fork 函数有一个惰性参数a: => Par[A]，这意味着a 在fork(a) 被提交到ExecutorService 和Callable 之前不会评估，因为a 的响应类型还有Par[A]，它也会再次异步eval，也可以递归 fork 用相同的ExecutorService执行。

所以据我了解，fork 带有 惰性参数 a: => Par[A]，它将具有并行和递归分叉任务的能​​力。

---

在Scala中，惰性函数：意思是惰性求值，直到调用这个函数。对于您的示例，您正在声明一个 惰性函数 a: => Par[A]，因此当您调用 fork 方法时，例如：fork(myFunction())，这不会立即评估 myFunction，它只会在 @ 时评估987654335@被执行。

例子：

def fun(a: => Int): Int = {
  println("second run")
  a
}

def fun2(): Int = {
  println("first run")
  1 + 1
}

fun(fun2())

上面的代码会输出如下：

第二次运行

第一次运行

因为提交fun2() 作为lazy function 不会被fun(fun2()) 评估，它将在方法fun 中评估。