Home
last modified time | relevance | path

Searched refs:queuePool (Results 1 – 3 of 3) sorted by relevance

/ohos5.0/foundation/ai/ai_engine/test/common/queuepool/
H A Dqueuepool_test.cpp55 ASSERT_NE(queuePool, nullptr);
69 ASSERT_NE(queuePool, nullptr);
85 ASSERT_NE(queuePool, nullptr);
101 ASSERT_NE(queuePool, nullptr);
122 queuePool->Push(queue);
140 if (queuePool == nullptr) {
158 queue = queuePool->Pop();
162 queue = queuePool->Pop();
180 queuePool->Push(queue);
493 queuePool->Push(queue);
[all …]
/ohos5.0/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dengine_manager.cpp209 QueuePool<Task> *queuePool = QueuePool<Task>::GetInstance(MAX_SYNC_MSG_NUM); in CreateEngine() local
210 CHK_RET(queuePool == nullptr, RETCODE_OUT_OF_MEMORY); in CreateEngine()
211 std::shared_ptr<Queue<Task>> queue = queuePool->Pop(); in CreateEngine()
222 queuePool->Push(queue); in CreateEngine()
231 queuePool->Push(queue); in CreateEngine()
H A Dengine.cpp111 QueuePool<Task> *queuePool = QueuePool<Task>::GetInstance(); in Uninitialize() local
112 if (queuePool == nullptr) { in Uninitialize()
116 queuePool->Push(queue_); in Uninitialize()