Home
last modified time | relevance | path

Searched defs:threadPool (Results 1 – 11 of 11) sorted by relevance

/foundation/communication/ipc/ipc/native/test/unittest/common/
Dipc_thread_pool_unittest.cpp55 IPCWorkThreadPool threadPool(1); variable
77 IPCWorkThreadPool threadPool(1); variable
97 IPCWorkThreadPool threadPool(1); variable
117 IPCWorkThreadPool threadPool(1); variable
135 IPCWorkThreadPool threadPool(1); variable
150 IPCWorkThreadPool threadPool(1); variable
/foundation/communication/ipc/ipc/native/c/manager/src/
Dipc_thread_pool.c65 ThreadPool *threadPool = GetCurrentSkeleton()->threadPool; in ThreadContextDestructor() local
111 ThreadPool *threadPool = (ThreadPool*)calloc(1, sizeof(ThreadPool)); in InitThreadPool() local
126 void DeinitThreadPool(ThreadPool *threadPool) in DeinitThreadPool()
140 int32_t SpawnNewThread(ThreadPool *threadPool, int32_t policy, int32_t proto) in SpawnNewThread()
183 void UpdateMaxThreadNum(ThreadPool *threadPool, int32_t maxThreadNum) in UpdateMaxThreadNum()
/foundation/ai/ai_engine/test/common/threadpool/
Dthread_pool_test.cpp164 ThreadPool *threadPool = ThreadPool::GetInstance(); variable
181 ThreadPool *threadPool = ThreadPool::GetInstance(); variable
197 ThreadPool *threadPool = ThreadPool::GetInstance(); variable
217 ThreadPool *threadPool = ThreadPool::GetInstance(); variable
/foundation/ai/ai_engine/services/server/communication_adapter/source/
Dclient_listener_handler.cpp156 ThreadPool *threadPool = ThreadPool::GetInstance(); in StartAsyncProcessThread() local
188 ThreadPool *threadPool = ThreadPool::GetInstance(); in StopAsyncProcessThread() local
/foundation/ai/ai_engine/services/client/communication_adapter/source/
Dsa_client_adapter.cpp128 ThreadPool *threadPool = ThreadPool::GetInstance(); in InitAiServer() local
160 ThreadPool *threadPool = ThreadPool::GetInstance(); in CloseAiServer() local
/foundation/ai/ai_engine/services/server/server_executor/source/
Dengine.cpp104 ThreadPool *threadPool = ThreadPool::GetInstance(); in Uninitialize() local
Dengine_manager.cpp201 ThreadPool *threadPool = ThreadPool::GetInstance(); in CreateEngine() local
/foundation/communication/ipc/ipc/native/c/manager/include/
Dipc_process_skeleton.h49 ThreadPool *threadPool; member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
Druntime_context_impl.cpp792 void RuntimeContextImpl::SetThreadPool(const std::shared_ptr<IThreadPool> &threadPool) in SetThreadPool()
807 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in ScheduleTaskByThreadPool() local
818 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in SetTimerByThreadPool() local
852 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in ModifyTimerByThreadPool() local
875 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in RemoveTimerByThreadPool() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
Druntime_config.cpp173 void RuntimeConfig::SetThreadPool(const std::shared_ptr<IThreadPool> &threadPool) in SetThreadPool()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
Ddistributeddb_communicator_test.cpp455 auto threadPool = std::make_shared<ThreadPoolTestStub>(); variable