C++中Boost Signal实现多播委托与观察者模式

基础回调与多播机制

Boost.Signal提供了一种声明式的信号槽接口，允许一个信号对象（Signal）连接多个槽函数（Slots）。当信号被触发时，所有已连接的槽函数都会按顺序执行。这种机制非常适合用于解耦事件发布者与订阅者。

以下示例展示了如何定义一个接收两个浮点数参数的信号，并连接三个不同的打印函数。当执行 sig(5, 3) 时，这三个函数将依次被执行：

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

void print_sum(float x, float y)
{
    std::cout << "The sum is " << x+y << std::endl;
}

void print_product(float x, float y)
{
    std::cout << "The product is " << x*y << std::endl;
}

void print_difference(float x, float y)
{
    std::cout << "The difference is " << x-y << std::endl;
}

int main()
{
    // 声明信号类型：返回值为void，参数为(float, float)
    boost::signal<void (float, float)> sig;

    // 连接回调函数
    sig.connect(print_sum);
    sig.connect(print_product);
    sig.connect(print_difference);

    // 触发信号，所有注册的函数将被执行
    sig(5, 3);

    return 0;
}

连接类成员函数

在实际应用中，通常需要让某个类的实例来响应信号。Boost.Signal原生支持通过Lambda表达式或 boost::bind 来连接类成员函数。使用Lambda是目前最为简洁且直观的方式，它能够自动捕获当前对象的状态。

以下代码演示了如何创建一个结构体A，并将其成员函数 Foo 连接到无参信号上：

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

struct A
{
    int value;
    A(int val) : value(val) {}
    
    void Foo() { 
        std::cout << "a has value of " << value << std::endl; 
    }
};

int main()
{
    A a(123);
    boost::signal<void ()> sig;

    // 使用Lambda捕获对象引用并调用成员函数
    sig.connect([&]() { a.Foo(); });
    
    // 触发信号
    sig();
    
    return 0;
}

处理带返回值的信号

与某些只支持void的信号机制不同，Boost.Signal同样支持带有返回值的信号。其规则类似于C#的委托组合：信号的返回值等于最后一个被调用的槽函数的返回值。前面的槽函数即使有返回值也会被忽略。

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

int main()
{
    // 定义返回int类型的信号
    boost::signal<int ()> sig;
    
    sig.connect([](){ return 1; });
    sig.connect([](){ return 2; });
    sig.connect([](){ return 3; });
    
    // 输出结果为3，即最后一个函数的返回值
    std::cout << sig() << std::endl;
    
    return 0;
}

异常处理与安全机制

在默认配置下，Boost.Signal的异常处理行为与C#相似：**如果在执行过程中某个槽函数抛出异常，后续的槽函数将不再执行，并且该异常会向上层调用者抛出**。这有助于确保事件链在遇到严重错误时及时中断，防止状态不一致。

#include <iostream>
#include <exception>
#include <boost/signal.hpp>

int main()
{
    boost::signal<void ()> sig;
    
    sig.connect([](){ std::cout << "foo 1 executed" << std::endl; });
    sig.connect([](){ throw std::exception("foo 2 fail"); });
    // foo 3 不会被执行
    sig.connect([](){ std::cout << "foo 3 executed" << std::endl; });

    try
    {
        sig();
    }
    catch (std::exception& error)
    {
        std::cout << "Caught exception: " << error.what() << std::endl;
    }
    
    return 0;
}

若需自定义异常处理策略（例如让所有槽函数都执行完，无论是否报错），可以通过向 connect 传递特定的策略对象来实现，但在大多数常规业务场景下，默认的“遇错即停”机制足以满足安全性需求。

以上就是Boost Signal实现多播委托与观察者模式的详细内容，更多关于C++高级特性、Boost库应用及事件驱动设计的资料请关注本站其它相关文章！