| /foundation/communication/ipc/ipc/native/test/unittest/common/ |
| D | ipc_thread_pool_unittest.cpp | 56 IPCWorkThreadPool threadPool(1); variable
78 IPCWorkThreadPool threadPool(1); variable
98 IPCWorkThreadPool threadPool(1); variable
118 IPCWorkThreadPool threadPool(1); variable
136 IPCWorkThreadPool threadPool(1); variable
151 IPCWorkThreadPool threadPool(1); variable
|
| /foundation/communication/ipc/ipc/native/c/manager/src/ |
| D | ipc_thread_pool.c | 69 ThreadPool *threadPool = ipcSkeleton->threadPool; in ThreadContextDestructor() local
115 ThreadPool *threadPool = (ThreadPool*)calloc(1, sizeof(ThreadPool)); in InitThreadPool() local
130 void DeinitThreadPool(ThreadPool *threadPool) in DeinitThreadPool()
145 int32_t SpawnNewThread(ThreadPool *threadPool, int32_t policy, int32_t proto) in SpawnNewThread()
188 void UpdateMaxThreadNum(ThreadPool *threadPool, int32_t maxThreadNum) in UpdateMaxThreadNum()
|
| /foundation/communication/ipc/test/fuzztest/ipc/native/src/core/ipcthreadpool_fuzzer/ |
| D | ipcthreadpool_fuzzer.cpp | 38 IPCWorkThreadPool threadPool(threadPoolSize); in RemoveThreadFuzzTest() local
50 IPCWorkThreadPool threadPool(maxThreadNum); in IPCWorkThreadPoolFuzzTest() local
61 IPCWorkThreadPool threadPool(0); in UpdateMaxThreadNumFuzzTest() local
|
| /foundation/ai/ai_engine/test/common/threadpool/ |
| D | thread_pool_test.cpp | 164 ThreadPool *threadPool = ThreadPool::GetInstance(); variable
181 ThreadPool *threadPool = ThreadPool::GetInstance(); variable
197 ThreadPool *threadPool = ThreadPool::GetInstance(); variable
217 ThreadPool *threadPool = ThreadPool::GetInstance(); variable
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/test/src_unit_test/src/threading/ |
| D | task_queue_test.cpp | 217 auto threadPool = factory->CreateThreadPool(4U); variable
268 auto threadPool = factory->CreateThreadPool(4); variable
306 auto threadPool = factory->CreateThreadPool(4); variable
353 auto threadPool = factory->CreateThreadPool(4); variable
375 auto threadPool = factory->CreateThreadPool(4); variable
421 auto threadPool = factory->CreateThreadPool(4); variable
493 auto threadPool = factory->CreateThreadPool(1); variable
513 auto threadPool = factory->CreateThreadPool(4); variable
556 auto threadPool = factory->CreateThreadPool(4); variable
601 auto threadPool = factory->CreateThreadPool(4U); variable
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/api/core/util/ |
| D | parallel_sort.h | 54 void ParallelSort(RandomIt first, RandomIt last, Compare comp, IThreadPool* threadPool) in ParallelSort()
127 void ParallelSort(RandomIt first, RandomIt last, IThreadPool* threadPool) in ParallelSort()
|
| /foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/task_group/ |
| D | task_group.cpp | 23 …Group::TaskGroup(const std::string& name, TaskFunc func, bool serial, const ThreadPool* threadPool) in TaskGroup()
|
| D | delayed_task_group.cpp | 23 …edTaskGroup::DelayedTaskGroup(const std::string& name, TaskFunc func, const ThreadPool* threadPool) in DelayedTaskGroup()
|
| D | base_task_group.cpp | 22 …p::BaseTaskGroup(const std::string& name, TaskFunc func, bool serial, const ThreadPool* threadPool) in BaseTaskGroup()
|
| /foundation/communication/ipc/test/fuzztest/ipc/native/src/core/ipcthreadpoolnew_fuzzer/ |
| D | ipcthreadpoolnew_fuzzer.cpp | 27 IPCWorkThreadPool threadPool(maxThreadNum); in SpawnThreadFuzzTest() local
|
| /foundation/ai/ai_engine/services/server/communication_adapter/source/ |
| D | client_listener_handler.cpp | 156 ThreadPool *threadPool = ThreadPool::GetInstance(); in StartAsyncProcessThread() local
188 ThreadPool *threadPool = ThreadPool::GetInstance(); in StopAsyncProcessThread() local
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| D | task_queue.cpp | 45 TaskQueue::TaskQueue(const IThreadPool::Ptr& threadPool) : threadPool_(threadPool), isRunningAsync_… in TaskQueue()
|
| D | dispatcher_task_queue.cpp | 34 DispatcherTaskQueue::DispatcherTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool… in DispatcherTaskQueue()
|
| D | parallel_task_queue.cpp | 37 ParallelTaskQueue::ParallelTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool) {} in ParallelTaskQueue()
|
| /foundation/ai/ai_engine/services/client/communication_adapter/source/ |
| D | sa_client_adapter.cpp | 128 ThreadPool *threadPool = ThreadPool::GetInstance(); in InitAiServer() local
160 ThreadPool *threadPool = ThreadPool::GetInstance(); in CloseAiServer() local
|
| /foundation/ai/ai_engine/services/server/server_executor/source/ |
| D | engine.cpp | 104 ThreadPool *threadPool = ThreadPool::GetInstance(); in Uninitialize() local
|
| D | engine_manager.cpp | 201 ThreadPool *threadPool = ThreadPool::GetInstance(); in CreateEngine() local
|
| /foundation/communication/ipc/ipc/native/c/manager/include/ |
| D | ipc_process_skeleton.h | 49 ThreadPool *threadPool; member
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/src/ |
| D | engine.cpp | 137 …auto threadPool = threadFactory->CreateThreadPool(GetThreadPoolThreadCount(threadFactory->GetNumbe… in CreateEcs() local
146 IEcs::Ptr Engine::CreateEcs(IThreadPool& threadPool) in CreateEcs()
|
| /foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/ |
| D | task_registry.cpp | 24 TaskRegistry::TaskRegistry(const std::string& name, const ThreadPool* threadPool) in TaskRegistry()
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/test/api_unit_test/src/util/ |
| D | parallel_sort_test.cpp | 153 Core::IThreadPool::Ptr threadPool = ecs->GetThreadPool(); variable
|
| /foundation/multimedia/av_codec/test/unittest/codeclist_test/ |
| D | caps_unit_test.cpp | 1365 std::vector<std::thread> threadPool; variable
1385 std::vector<std::thread> threadPool; variable
1406 std::vector<std::thread> threadPool; variable
1426 std::vector<std::thread> threadPool; variable
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| D | runtime_context_impl.cpp | 991 void RuntimeContextImpl::SetThreadPool(const std::shared_ptr<IThreadPool> &threadPool) in SetThreadPool()
1006 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in ScheduleTaskByThreadPool() local
1017 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in SetTimerByThreadPool() local
1051 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in ModifyTimerByThreadPool() local
1074 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in RemoveTimerByThreadPool() local
|
| /foundation/multimedia/camera_framework/frameworks/native/camera/test/unittest/camera_deferred_unittest/camera_deferred_base_test/src/ |
| D | camera_deferred_base_unittest.cpp | 141 …std::shared_ptr<ThreadPool> threadPool = std::make_shared<ThreadPool>("camera_deferred_base", numT… variable
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| D | runtime_config.cpp | 192 void RuntimeConfig::SetThreadPool(const std::shared_ptr<IThreadPool> &threadPool) in SetThreadPool()
|