C++ 响应式编程：库与实践

C++ 响应式编程：现代事件处理方法

响应式编程 (Reactive Programming) 是一种面向异步数据流和变化传播的编程范式。在 C++ 中，这一概念允许构建灵活、响应迅速且易于维护的应用程序，尤其在 GUI、网络通信和信号处理领域。与传统的命令式方法（您明确指定操作顺序）不同，响应式编程描述数据之间的依赖关系：当一个元素发生变化时，所有依赖它的元素都会自动更新。

响应式编程的核心概念

• Observable (可观察对象) — 生成事件的数据源。
• Observer (观察者) — 响应事件的订阅者。
• Subscription (订阅) — Observable 和 Observer 之间的连接。
• 操作符 — 用于转换、过滤和组合流的函数 (map, filter, merge, switch_on_next)。

在 C++ 中，响应式编程通过提供这些抽象的库来实现。我们来看三种最流行的工具。

1. RxCpp — C++ 的 Reactive Extensions 库

RxCpp 是流行的 ReactiveX (Rx) 模型在 C++ 上的移植。它提供了一套强大的操作符来处理异步流。该库使用现代 C++17/20、模板和 lambda 表达式。

示例：简单订阅数字流

#include <rxcpp/rx.hpp>#include <iostream>

int main() {    // 创建一个可观察的数字流    auto observable = rxcpp::observable<>::range(1, 5);

    // 订阅    observable.subscribe(        [](int v) { std::cout << "收到: " << v << std::endl; }, // on_next        []() { std::cout << "完成!" << std::endl; }            // on_completed    );

    return 0;}

示例：过滤和转换

#include <rxcpp/rx.hpp>#include <iostream>

int main() {    auto values = rxcpp::observable<>::range(1, 10)        .filter([](int x) { return x % 2 == 0; })  // 仅偶数        .map([](int x) { return x * x; });         // 求平方

    values.subscribe([](int v) { std::cout << v << " "; });    // 输出: 4 16 36 64 100

    return 0;}

RxCpp 特点：

• 支持多线程和调度器 (schedulers)。
• 丰富的操作符集 (merge, zip, combine_latest, debounce, throttle)。
• 与 std::future 和异步操作集成。
• 兼容 CMake 和 vcpkg。

2. Boost.Signals2 — 无外部依赖的信号与槽

Boost.Signals2 是 Boost 库中的一部分，实现了信号与槽机制。它是原始 Boost.Signals 的线程安全演进版本。非常适合事件驱动架构，尤其是在 GUI 和游戏引擎中。

示例：带两个槽的简单信号

#include <boost/signals2.hpp>#include <iostream>

void hello() { std::cout << "Hello, "; }void world() { std::cout << "world!" << std::endl; }

int main() {    boost::signals2::signal<void()> sig;

    sig.connect(&hello);    sig.connect(&world);

    sig();  // 调用信号 — 将调用两个槽    // 输出: Hello, world!

    return 0;}

示例：带参数和返回值的信号

#include <boost/signals2.hpp>#include <iostream>#include <string>