线程内队列的关键部分

我有一个单例事件类，上面有一个队列和线程。实现就像，有几个模块/对象订阅某些事件并能够发布多个事件。

此事件类的目的是在将其推送到队列时接收所有这些事件，并且此类中的线程需要弹出事件并将其发送到相应的订阅模块/对象。

背后的想法是创建一个基于 c++ 的事件聚合器，它可以在 C# 上使用。

实现就像

    void c_eventAggregator::PostEvent(EVENT_UID EventUid)
{
    c_criticalRegion criticalRegion(eASyncObj);
    Queue.push_back(EventUid);
    criticalRegion.~c_criticalRegion();
}
void c_eventAggregator::DispatchEventToClients(EVENT_UID EventUid)
{
    EventClientsList eclist = _eventIdSubsList[EventUid];
    for (EventClientsList::iterator iter = eclist.begin(); iter != eclist.end(); iter++) {
        iter->second->receiveEvent(EventUid);
    }
}
int c_eventAggregator::SubscribeEvent(EVENT_CLIENTID clientId, c_eventClient *ecPtr, EVENT_UID EventUid)
{
    try
    {
        _eventIdSubsList[EventUid].insert(make_pair(clientId, ecPtr));
    }
    catch (int exception)
    {
        return exception;
    }
    return ZERO_VALUE;
}
void c_eventAggregator::run(void)
{
    EVENT_UID EventUid;
    while (isAlive())
    {
        while (Queue.size())
        {
            if (!Queue.empty())
            {
                c_criticalRegion criticalRegion(eASyncObj);
                EventUid = Queue[0];
                Queue.pop_front();
                DispatchEventToClients(EventUid);
                criticalRegion.~c_criticalRegion();
            }
        }
    }
}

我在推送和弹出之间使用关键部分，以便在多个模块/对象同时写入时队列不会被覆盖。（不确定这是否正确）。

我的关键部分处理程序就像

class c_criticalRegion{
  public:
    c_criticalRegion(c_syncObject &paSyncObject) : mSyncObject(paSyncObject){
      mSyncObject.lock();
    }
    ~c_criticalRegion(){
      mSyncObject.unlock();
    }
  private:
    c_syncObject &mSyncObject;
};

对象类似于同步.cpp，

c_syncObject::c_syncObject(){
    InitializeCriticalSection(&m_oMutexHandle);
}
c_syncObject::~c_syncObject(){
    DeleteCriticalSection(&m_oMutexHandle);
}

同步.h：

class c_syncObject{
private:
protected:
    //! The win32 CRITICAL_SECTION handle of the operating system.
    CRITICAL_SECTION m_oMutexHandle;
public:
    c_syncObject();
    ~c_syncObject();
    /*!brief Lock the resource coming after the lock command
    *
    * This function blocks until it will get the lock for the coming critical section.
    */
    void lock(void){
        EnterCriticalSection(&m_oMutexHandle);
        //TODO handle return value
    };
    //!Free the resource coming after the lock command  
    void unlock(void){
        LeaveCriticalSection(&m_oMutexHandle);
        //TODO handle return value
    };
};

我在这里面临的问题是，除非我在 PostEvent（） 中注释criticalRegion.~c_criticalRegion()，否则代码有时不起作用。同样，当有事件发送到 PostEvent 时，run()内的队列仍显示大小为零。

这有点微不足道，我最终在其他具有类似实现的文件上也会遇到相同的情况。

我也想知道，当发布关键部分时，在完成任务后DispatchEventToClients()或之前。