Poco - 安全地使用 removeObserver

Question

我在 Activity 线程中有一个通知中心：

Poco::NotificationCentre nc;   // publicly visible

// (thread main loop which will post notifications from time to time)

还有多个作用于通知的工作线程。然而，那些等待通知的线程也可能需要在外部发出信号以随时退出。所以我在我的工作线程中有以下内容（这也是伪代码，为了清楚起见省略了一些细节）

Poco::Event event;
std::string s;
MyNotificationClass notifier{event, s};  // holds those by reference
Poco::NObserver<MyNotificationClass, MyNotification> obs(notifier, &MyNoficationClass::func);

nc.addObserver(obs);
event.wait();
nc.removeObserver(obs);

return s;

通知类是：

struct MyNotificationClass
{
    MyNotificationClass(Poco::Event &ev, std::string &s): ev(ev), s(s) {}
    void func(const Poco::AutoPtr<MyNotification> &p)
    {
        s = p->s;
        ev.set();
    }
    Poco::Event &ev;
    std::string &s;
};

我担心的是，即使在工作线程中调用removeObserver之后，通知中心也可能同时收到了通知，所以工作线程具有的函数中的对象s刚刚returned from 在它被销毁后可能会被访问​​。

我的问题是：这是一个有效的问题吗？如果是，我应该怎么做才能确保在return 之后不会发生通知？

Answer 1

编辑：因为removeObserver() 是disabling 被移除的观察者，所以上面的代码是安全的。下面的答案留作记录，以便理解 cmets 部分。

---

原答案：

这是一个有效的问题 - 工作线程函数可以在 add/removeObserver() 调用之间被抢占。由于postNotification()makes a copy*在所有观察者的指针中，如果有多个来自其他线程的通知，在你调用removeObserver()（甚至函数返回后）。

现在，无需担心函数返回后会访问观察者，因为它是由通知中心将cloned 转换为SharedPtr。然而，由于 NObserver 持有它的naked address，因此此时调用通知处理程序存在问题。为防止坏事发生，请在从函数返回之前调用 obs.disable() - 这将通过 disarm 以线程安全的方式处理任何待处理通知。

---

* _{出于性能原因 - 我们不想在所有通知处理程序正在执行时阻塞 NotificationCenter 的其余部分。}