Home
last modified time | relevance | path

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

/foundation/ai/ai_engine/test/common/queuepool/
H A Dqueuepool_test.cpp54 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); in HWTEST_F() local
55 ASSERT_NE(queuePool, nullptr); in HWTEST_F()
68 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); in HWTEST_F() local
69 ASSERT_NE(queuePool, nullptr); in HWTEST_F()
70 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F()
84 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); in HWTEST_F() local
85 ASSERT_NE(queuePool, nullptr); in HWTEST_F()
86 auto busyNum = queuePool->BusyQueueNum(); in HWTEST_F()
100 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); in HWTEST_F() local
101 ASSERT_NE(queuePool, nullpt in HWTEST_F()
118 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
137 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
153 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
176 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
213 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
234 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
255 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
272 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
292 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
312 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
338 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
358 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
380 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
409 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
427 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
456 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
488 QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY); HWTEST_F() local
[all...]
/foundation/ai/ai_engine/services/server/server_executor/source/
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()
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()

Completed in 2 milliseconds