Home
last modified time | relevance | path

Searched refs:DeQueue (Results 1 - 7 of 7) sorted by relevance

/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dmessage_queue.h32 MessageDataType DeQueue() in DeQueue() function in Commonlibrary::Concurrent::TaskPoolModule::final
H A Dtaskpool.cpp129 auto resultInfo = msgQueue.DeQueue(); in ExecuteCallbackInner()
/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dmessage_queue.h29 bool DeQueue(MessageDataType *data);
H A Dmessage_queue.cpp27 bool MessageQueue::DeQueue(MessageDataType *data) in DeQueue() function in Commonlibrary::Concurrent::WorkerModule::MessageQueue
H A Dworker.cpp950 if (!worker->workerGlobalCallQueue_.DeQueue(&data)) { in GlobalCall()
1422 while (hostMessageQueue_.DeQueue(&data)) { in HostOnMessageInner()
1713 while (errorQueue_.DeQueue(&data)) { in HostOnErrorInner()
1946 while (!IsTerminated() && workerMessageQueue_.DeQueue(&data)) { in WorkerOnMessageInner()
/commonlibrary/ets_utils/js_concurrent_module/worker/test/
H A Dtest_worker.cpp96 while (worker->workerMessageQueue_.DeQueue(&data)) { in WorkerOnMessage()
127 while (worker->hostMessageQueue_.DeQueue(&data)) { in HostOnMessage()
1559 ASSERT_FALSE(queue.DeQueue(&data)); in HWTEST_F()
1571 ASSERT_TRUE(queue.DeQueue(nullptr)); in HWTEST_F()
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest_taskpool.cpp408 auto result = mesQueue.DeQueue(); in HWTEST_F()

Completed in 40 milliseconds