GHC Haskell线程间基本值计算同步机制咨询

先来看你的示例代码：

import Control.Concurrent
expensiveFunction x = sum [1..x] -- Just an example
val = expensiveFunction 12345
thread1 = print val
thread2 = print val
main = do
    forkOS thread1
    forkOS thread2

你的问题问到了GHC runtime里一个很核心的惰性求值并发细节，刚好这部分是GHC自动帮我们处理的，不用手动加同步原语，我来给你拆解清楚：

1. 顶层绑定val的共享性 #

首先，val = expensiveFunction 12345是顶层绑定，在GHC编译后，整个程序里只会有一个对应的未求值闭包（thunk）实例——所有线程都会共享这个内存地址的闭包，thread1和thread2指向的是同一个val，不是各自复制一份。

2. 首次求值的同步过程 #

当第一个线程（比如thread1）执行print val时，会触发val的求值，这个过程GHC runtime会自动做以下几件事：

• 它会把这个thunk的状态标记为**“正在求值”**（这是原子操作，不会有并发冲突）
• 然后thread1开始执行expensiveFunction 12345计算结果
• 这时候如果thread2也过来要求值val，它会检查thunk的状态，发现已经有线程在计算了，就会阻塞等待，直到计算完成

3. 求值完成后的结果传递 #

当thread1完成计算后，会做一个原子性的替换操作：把原来的thunk直接替换成计算好的整数结果。这个替换完成后，所有等待的线程（比如thread2）会被唤醒，然后直接读取已经计算好的结果，不会再重新执行expensiveFunction。

4. 为什么不需要IORef/TVar？ #

GHC的惰性求值机制本身就内置了这种线程安全的“首次求值同步”，专门用来处理共享thunk的并发访问问题。这种机制叫做thunk的线程安全memoization，是runtime层面实现的。而IORef、TVar这类原语是用来处理需要多次修改的可变状态，你的场景里val是一次性计算、永久不变的，刚好适配GHC的默认行为。

你的代码的具体运行流程 #

最后再对应你的代码梳理一遍：

• 程序启动时，val是一个未求值的thunk
• main函数fork出thread1，thread1执行print val触发求值，runtime标记thunk为“正在计算”
• 接着fork出thread2，thread2执行print val时检测到thunk正在被计算，进入阻塞等待
• thread1完成expensiveFunction的计算，原子替换thunk为结果，唤醒thread2
• 两个线程最终都打印同一个结果，且expensiveFunction只会被执行一次

完全不用担心重复计算或者竞争的问题，GHC已经把这些细节都封装在runtime里了。

内容的提问来源于stack exchange，提问作者jforberg