FoundationDB Flow：将Actor并发模型引入C++11

标题：FoundationDB's Flow – Bringing Actor-Based Concurrency to C++11

背景

FoundationDB 最初的目标是实现节点级高性能与集群级可扩展性。在开发核心组件时，必须面对复杂工程挑战：既要支持 Erlang 或 .NET Async 那样的高效异步通信进程，又需保留 C++ 的原始速度与 I/O 效率，还要通过大规模模拟验证可靠性与容错能力。

为突破这些限制，团队开发了多项新工具，其中最重要的是 Flow。Flow 是一种将 actor-based 并发模型引入 C++11 的新编程语言。它通过添加约 10 个新关键词和控制流原语，实现异步消息传递与协作，同时输出原生 C++11 代码，由传统编译器处理。Flow 编译器会分析异步函数（actor），将其重写为包含大量子函数的对象，使用回调避免阻塞（类似 JavaScript 的 streamlinejs 概念）。其输出仍是标准 C++11 代码，可直接编译为二进制文件。Flow 同时为模拟工具提供输入，支持对整个系统（含物理接口与故障模式）的确定性模拟。

核心内容

工程挑战

FoundationDB 追求节点高性能与集群可扩展性，开发过程中面临三类核心挑战：实现高效异步通信进程、保留 C++ 速度与 I/O 效率，以及进行大规模可靠性与容错模拟。

核心解决方案：Flow

Flow 通过编译器实现 actor-based 并发。编译器分析异步函数（actor），将其重写为包含多个子函数的对象，使用回调机制避免阻塞。输出为普通 C++11 代码，可由传统工具编译。Flow 还直接为模拟工具提供输入，支持确定性模拟整个集群及其物理接口与故障模式。

通过 Flow，可在 C++ 中实现高效并发，同时保持可维护性与可扩展性，从而同时满足高性能（编译为本地代码）、actor-based 并发（提升开发效率）和模拟支持（支持测试）三大目标。

基本概念：Actors 与消息传递

在 Flow 中，actors 通过 Future<T> 数据类型接收异步消息。当 actor 需要特定数据继续计算时，它会调用 wait() 等待该数据，而不会阻塞其他 actors。以下是简单的异步加法示例：

ACTOR Future<int> asyncAdd(Future<int> f, int offset) {
    int value = wait(f);
    return value + offset;
}

核心特性

• Promise<T> 和 Future<T>：连接异步发送方与接收方的类型。持有 Promise<T> 表示承诺在未来交付类型 T 的值；持有 Future<T> 的接收方可异步继续计算，直到真正需要 T。Promise 和 Future 可在同一进程内使用，也可跨越网络传输。
• wait()：接收方持有 Future<T> 时，通过 wait() 语句暂停执行直到值就绪，返回 T。在等待期间，其他 actors 可继续执行，实现进程内异步并发。只有标记为 ACTOR 的函数才能调用 wait()。Actors 是异步工作的基本单元，可通过组合形成复杂消息传递系统。
• State：使用 state 关键词限定变量，使其在 actor 内多个 wait() 语句间可见。
• PromiseStream<T> 和 FutureStream<T>：处理异步消息流，支持复用和可靠交付。许多 FoundationDB 服务器接口通过 promise streams 结构体暴露（每个请求类型一个）。
• waitNext()：FutureStream 的 wait() 对应版本，暂停执行等待流中下一个值。
• choose … when：允许 actor 以有序可预测方式等待多个 Future。基础服务器接口示例中，serveCountingServerInterface 函数使用 while 循环与 choose-when 组合，处理 addCount、subtractCount 和 getCount 请求，保存状态变量 count。

ACTOR void serveCountingServerInterface(CountingServerInterface csi) {
    state int count = 0;
    while (1) {
        choose {
            when (int x = waitNext(csi.addCount.getFuture())) {
                count += x;
            }
            when (int x = waitNext(csi.subtractCount.getFuture())) {
                count -= x;
            }
            when (Promise<int> r = waitNext(csi.getCount.getFuture())) {
                r.send(count);  // 发送回复给客户端
            }
        }
    }
}

Caveats（注意事项）

• Flow 与 C++ 的区别：Flow 代码与 C++ 语法类似，但有不同规则，文件需预处理。建议使用 actorcompiler.h 头文件定义预处理器宏，使 Flow 编译为普通 C++11 代码。CMake 支持 -DOPEN_FOR_IDE=ON 模式，避免预处理，并生成 compile_commands.json 以支持 IDE（如 cquery、clang-based 完成引擎）。

• 编程注意事项：

  • Local variables 在 wait() 调用后不会保留：

    ACTOR void foo {
        int i = 0;
        wait(someFuture);
        int i = 2;  // 这是错误的 Flow 代码
        wait(someOtherFuture);
    }
    

    可通过变量重命名或显式作用域解决。
  • ACTOR 函数编译为内部类，this 指针在函数内有效，但使用 this 会破坏 IDE 支持。应使用 THIS 和 THIS_ADDR。

关键要点

• Flow 是 FoundationDB 核心的 actor-based 并发工具，编译器将异步 actor 重写为 C++11 回调结构，输出原生代码。
• 核心 API：Promise<T>/Future<T>（支持跨进程与网络）、wait()（非阻塞等待）、waitNext()（流处理）、choose … when（多路等待）。
• 通过 state 变量、streams 与 choose-when，可轻松构建分布式服务器接口（如计数服务器示例）。
• 预处理机制确保 IDE 支持，同时保持性能。
• Flow 直接服务于模拟工具，实现确定性全系统测试。

意义与影响

Flow 为 C++ 开发者提供了 Erlang 级别的 actor 模型，却无需牺牲 C++ 的性能与控制权。编译器+原生代码的路径既保持了开发效率，又保留了 I/O 效率与硬件级控制。这对需要极致性能与容错的分布式系统（如 FoundationDB）尤为关键：团队可在模拟环境中验证可靠性，实际部署时无需额外开销。

Flow 的影响超出 FoundationDB：它为 C++ 生态引入了易于维护的异步编程范式，成为其他系统参考的标杆。FoundationDB 正是通过 Flow 实现了从第一行代码到上线的高效率与卓越容错能力，证明了在高性能分布式系统中，高级抽象与底层效率可兼得。未来，类似工具可能推动更多 C++ 项目采用 actor 模型，提升复杂系统开发的整体质量。