MCPcopy Create free account
hub / github.com/Tencent/mars / ReleaseNewMessageQueue

Method ReleaseNewMessageQueue

mars/comm/messagequeue/message_queue.cc:973–980  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

971}
972
973void MessageQueueCreater::ReleaseNewMessageQueue(MessageQueue_t _messagequeue_id) {
974
975 if (KInvalidQueueID == _messagequeue_id) return;
976
977 BreakMessageQueueRunloop(_messagequeue_id);
978 WaitForRunningLockEnd(_messagequeue_id);
979 ThreadUtil::join((thread_tid)_messagequeue_id);
980}
981
982void MessageQueueCreater::__ThreadNewRunloop(SpinLock* _sp) {
983 ScopedSpinLock lock(*_sp);

Callers

nothing calls this directly

Calls 3

BreakMessageQueueRunloopFunction · 0.85
WaitForRunningLockEndFunction · 0.85
joinFunction · 0.85

Tested by

no test coverage detected