通用观测器模式

Question

我正在处理代码，其中有很多观察者模式实现。所有这些活动的组织方式如下：

观察者要实现的一些接口：

class ObserverInterface {
  virtual void FooOccurs() = 0;
};

实现注册、注销和通知的类：

class ObservableImpl {
  public:
    Register(ObserverInterface *observer);
    Unregister(ObserverInterface *observer);

  private:
    void SomeMethod() {
      // foo things
      for(auto &observer: observers) {
        observer.FooOccurs();
      }
    }
};

Answer 1

在C++11中，我建议使用基于令牌的方法。

你注册一个观察者。观察者只是一个std::function 。

注册函数返回一个令牌std::shared_ptr 。只要返回的shared_ptr有效，广播器就会继续向该监听器广播。

侦听器现在负责维护std::shared_ptr生存期。

在广播器内部，您在广播之前持有weak_ptr和.lock()。如果我真的不需要注销（通常我不需要），我会懒洋洋地清理我的weak_ptr列表。否则，返回的shared_ptr有一个删除函数执行取消注册。

或者，您的侦听器是shared_ptr > ion，您在内部将weak_ptr存储到该侦听器。

在这个模型中，您不能轻易地注入一个UnregistraTon函数。但是，这确实意味着他们可以使用别名构造函数自己来将回调的生存期紧密绑定到他们自己，假设他们是由shared_ptr管理的。

根据我的经验，只需让侦听器维护std::vector 就足够了。如果他们有一个更复杂的监听关系，他们可以做更多的工作，维护键等。

混合动力车型也是可以的。

对于非线程安全广播来说，这两种方法都是可以接受的，并且可以用几十行代码编写。

线程安全广播变得棘手。通常，我发现您最好使用消息传递模式，而不是替代模式，因为这会稍微降低并发推理的难度。

这也不能处理这样的情况，即你想随时注册听众，广播者和听众的生命周期就像爆米花一样。