c++ - 在容器中使用时断言在 boost::intrusive_ptr 中触发

Question

我有一个生产者-消费者安排来处理来自网络的事件。 Dispatcher 通过工作线程拥有的互斥锁保护队列为多个 EventHandler 线程提供工作。放入队列的事件对象使用boost::intrusive_ptr

class Event { ... }
typedef boost::intrusive_ptr<Event> EventPtr;

队列是一个模板，定义为:

template<typename Data>
class ConcurrentQueue : boost::noncopyable
{
protected:
    std::queue<Data> _queue;
    boost::mutex _dataMutex;
    boost::condition_variable _dataAvailable;
    ...
public:
    ...
    void push(Data const& data)
    {
        boost::mutex::scoped_lock lock(_dataMutex);
        _queue.push(data);
        lock.unlock();
        _dataAvailable.notify_one();
    }
...
};
...
typedef ConcurrentQueue<EventPtr> EventQueue;

EventHandler 等待事件放入其队列，并在可用时使用方法 waitAndPop 将其从队列中删除:

void waitAndPop(Data& poppedValue)
{
    boost::mutex::scoped_lock lock(_dataMutex);
    while(_queue.empty())
    {
        _dataAvailable.wait(lock);
    }
    poppedValue = _queue.front();
    _queue.pop();
}

这运行良好，但我随后需要确保 Dispatcher 将相关工作交给同一个 EventHandler。因此，我实现了一个 waitAndPeek 方法，将 Event 对象留在队列中，但返回指向它的指针。

void waitAndPeek(Data& peekedValue)
{
    boost::mutex::scoped_lock lock(_dataMutex);
    while(_queue.empty())
    {
        _dataAvailable.wait(lock);
    }
    peekedValue = _queue.front();
}

一旦事件处理完成，事件就会从队列中弹出。将事件留在队列中允许 Disptacher 检查队列头部的项目，看它是否与它试图分配的项目相关。 (以互斥保护的方式完成但未显示)

下面是从 EventQueue 中提取指针的代码:

EventPtr event;
// Loop, processing events placed on the queue.   
while (true)
{
    // Blocking call. Will halt the thread until there is work to do.
    _eventQueue->waitAndPeek(event);
    // Try to access event but ASSERT fires
    int id = event->getId();
    ...
}

问题是当我使用窥视指针时，intrusive_ptr 代码中触发了一个 ASSERT。

/usr/local/packages/Boost/1.40.0/include/boost/smart_ptr/intrusive_ptr.hpp:166:
T* boost::intrusive_ptr<T>::operator->() const [with T = Event]:
Assertion `px != 0' failed.

一旦我恢复代码以使用 waitAndPop 方法，问题就消失了，是什么导致 ASSERT 仅仅因为我将事件留在队列中而触发？

Answer 1

查看 intrusive_ptr 文档:

http://www.boost.org/doc/libs/1_46_1/libs/smart_ptr/intrusive_ptr.html#indirection

为了取消引用它，它必须持有一个非 NULL 指针。