Method readMessage

native/cocos/base/threading/MessageQueue.cpp:259–274

}

Message *MessageQueue::readMessage() noexcept {
    while (!hasNewMessage()) { // if empty
        std::unique_lock<std::mutex> lock(_mutex);
        pullMessages();          // try pulling data from consumer
        if (!hasNewMessage()) {  // still empty
            _condVar.wait(lock); // wait for the producer to wake me up
            pullMessages();      // pulling again
        }
    }

    Message *const msg = _reader.lastMessage->getNext();
    _reader.lastMessage = msg;
    --_reader.newMessageCount;
    CC_ASSERT(msg);
    return msg;
}

MessageQueue::~MessageQueue() {
    recycleMemoryChunk(_writer.currentMemoryChunk);