Searched refs:m_localMsgQueue (Results 1 – 1 of 1) sorted by relevance
48 QUEUE *m_localMsgQueue = nullptr; variable65 m_localMsgQueue = new QUEUE(); in RenderThread()73 delete m_localMsgQueue; in ~RenderThread() local79 …cvFull.wait(lk, [this]() { return (m_localMsgQueue->GetSize() < this->qSize) || (!m_isWorking); }); in AddTask()82 … m_localMsgQueue->Remove([&task](LocalTaskType &t) { return GetTag(task) == GetTag(t); }); in AddTask()84 m_localMsgQueue->Push(task); in AddTask()93 while (m_localMsgQueue->GetSize() > 0) { in ClearTask()94 m_localMsgQueue->RemoveAll(); in ClearTask()128 [this]() { return (m_localMsgQueue->GetSize() > 0) || (!m_isWorking); }); in Run()131 bool ret = m_localMsgQueue->Pop(task); in Run()