Method CancelAndWait

mars/comm/messagequeue/message_queue.cc:935–946

}

void MessageQueueCreater::CancelAndWait() {
    ScopedLock lock(messagequeue_mutex_);

    if (KInvalidQueueID == messagequeue_id_) return;
    
    BreakMessageQueueRunloop(messagequeue_id_);
    messagequeue_id_ = KInvalidQueueID;
    lock.unlock();
    if(ThreadUtil::currentthreadid() != thread_.tid()) {
        thread_.join();
    }
}

MessageQueue_t MessageQueueCreater::CreateNewMessageQueue(boost::shared_ptr<RunloopCond> _breaker, thread_tid _tid) {
    return(__CreateMessageQueueInfo(_breaker, _tid));