c++双调度观察者通知

Question

以下是我当前正在排除故障的代码：

void CTimer::notify()
{
    std::vector<IObserver*>::iterator it;
    for(it=observers.begin();it!=observers.end();++it)
    {
        ITimerNotification* notification = new CTimerNotification(now());
        (*it)->readNotification(*notification);
    }
}

class CTimerNotification : public ITimerNotification
{
    public:
        CTimerNotification(const timeval& t)
        {
            time = t;
        }
    protected:
        timeval time;
    private:
        virtual ~CTimerNotification();
        virtual void read(const IObserver& o) const
        {
            o.update(*this);
        }
        virtual const timeval& getTime() const
        {
            return time;
        }
};

class IObserver
{
    public:
        virtual ~IObserver();
        virtual void readNotification(const INotification&) const=0;
        virtual void update(const INotification&) const=0;
};

class ITimerObserver : public IObserver
{
    public:
        virtual void update(const ITimerNotification&) const=0;
};

class TestObserver : public ITimerObserver
{
    public:
        virtual void readNotification(const INotification& n) const
        {
            n.read(*this);
        }
        virtual void update(const INotification& n) const
        {
            std::cout<<"???: TestObserver: update()!\n";
        }
        virtual void update(const ITimerNotification& n) const
        {
            std::cout<< n.getTime().tv_sec << "." << n.getTime().tv_usec <<": TestObserver: update()!\n";
        }
};

因此，代码运行后，CTimer::notify() 被调用，这会创建一个 TimerNotification 并通过 将其传递给观察者>readNotification() 依次调用通知的 read() 方法，该方法最终调用观察者的（希望）正确的 update() 方法。

最后一步就是失败的地方。它调用 update(INotification&) 方法，而不是所需的 update(ITimerNotification&) 方法。

为了使这种尝试的双重调度模式发挥作用，我在这里缺少什么？它似乎没有获得正确的类型信息来选择适当的函数调用。

感谢您的帮助！

Answer 1

CTimerNotification 需要一个read类似的东西

virtual void read(const IObserver& o) const {
    ITimerObserver* to = dynamic_cast<ITimerObserver*>(&o);
    if (to) {
        to->update(*this);
    } else {
        o.update(*this);
    }
}

，并且您需要在ITimerObserver中使用using IObserver::update;。