Function WaitForRunningLockEnd

mars/comm/messagequeue/message_queue.cc:218–237

}

void WaitForRunningLockEnd(const MessagePost_t&  _message) {
    if (Handler2Queue(Post2Handler(_message)) == CurrentThreadMessageQueue()) return;

    ScopedLock lock(sg_messagequeue_map_mutex);
    const MessageQueue_t& id = Handler2Queue(Post2Handler(_message));

    std::map<MessageQueue_t, MessageQueueContent>::iterator pos = sg_messagequeue_map.find(id);
    if (sg_messagequeue_map.end() == pos) return;
    MessageQueueContent& content = pos->second;
    
    if (content.lst_runloop_info.empty()) return;
    
    auto find_it = std::find_if(content.lst_runloop_info.begin(), content.lst_runloop_info.end(),
                                [&_message](const RunLoopInfo& _v){ return _message == _v.runing_message_id; });
    
    if (find_it == content.lst_runloop_info.end()) return;

    boost::shared_ptr<Condition> runing_cond = find_it->runing_cond;
    runing_cond->wait(lock);
}

void WaitForRunningLockEnd(const MessageQueue_t&  _messagequeueid) {
    if (_messagequeueid == CurrentThreadMessageQueue()) return;