Function BreakMessageQueueRunloop

mars/comm/messagequeue/message_queue.cc:278–292

}

void BreakMessageQueueRunloop(const MessageQueue_t&  _messagequeueid) {
    ASSERT(0 != _messagequeueid);

    ScopedLock lock(sg_messagequeue_map_mutex);
    const MessageQueue_t& id = _messagequeueid;

    std::map<MessageQueue_t, MessageQueueContent>::iterator pos = sg_messagequeue_map.find(id);
    if (sg_messagequeue_map.end() == pos) {
        //ASSERT2(false, "%llu", (unsigned long long)id);
        return;
    }

    pos->second.breakflag = true;
    pos->second.breaker->Notify(lock);
}

MessageHandler_t InstallMessageHandler(const MessageHandler& _handler, bool _recvbroadcast, const MessageQueue_t& _messagequeueid) {
    ASSERT(bool(_handler));