| /foundation/communication/ipc/ipc/native/test/unittest/common/ |
| D | ipc_thread_pool_unittest.cpp | 55 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/ |
| D | ipc_thread_pool.c | 65 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()
141 int32_t SpawnNewThread(ThreadPool *threadPool, int32_t policy, int32_t proto) in SpawnNewThread()
184 void UpdateMaxThreadNum(ThreadPool *threadPool, int32_t maxThreadNum) in UpdateMaxThreadNum()
|
| /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_2d/rosen/modules/2d_graphics/src/drawing/engine_adapter/skia_adapter/ |
| D | skia_gpu_context.h | 58 static std::unique_ptr<SkExecutor> threadPool; variable
|
| D | skia_gpu_context.cpp | 68 std::unique_ptr<SkExecutor> SkiaGPUContext::threadPool = nullptr; member in OHOS::Rosen::Drawing::SkiaGPUContext
|
| /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/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| D | task_queue.cpp | 50 TaskQueue::TaskQueue(const IThreadPool::Ptr& threadPool) : threadPool_(threadPool), isRunningAsync_… in TaskQueue()
|
| D | dispatcher_task_queue.cpp | 31 DispatcherTaskQueue::DispatcherTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool… in DispatcherTaskQueue()
|
| D | parallel_task_queue.cpp | 79 ParallelTaskQueue::ParallelTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool) {} in ParallelTaskQueue()
|
| /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/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/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/texture_encode/ |
| D | hwe_threadpool.cpp | 37 HWE_ThreadPool *threadPool = (HWE_ThreadPool *)pool; in HWE_ThreadPoolWorkerFunc() local
|
| /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/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 | 136 auto threadPool = threadFactory->CreateThreadPool(threadFactory->GetNumberOfCores()); in CreateEcs() local
143 IEcs::Ptr Engine::CreateEcs(IThreadPool& threadPool) in CreateEcs()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| D | runtime_context_impl.cpp | 956 void RuntimeContextImpl::SetThreadPool(const std::shared_ptr<IThreadPool> &threadPool) in SetThreadPool()
971 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in ScheduleTaskByThreadPool() local
982 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in SetTimerByThreadPool() local
1016 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in ModifyTimerByThreadPool() local
1039 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in RemoveTimerByThreadPool() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| D | runtime_config.cpp | 177 void RuntimeConfig::SetThreadPool(const std::shared_ptr<IThreadPool> &threadPool) in SetThreadPool()
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/src/ecs/ |
| D | ecs.cpp | 232 Ecs::Ecs(IClassFactory& registry, const IThreadPool::Ptr& threadPool) in Ecs()
664 IEcs* IEcsInstance(IClassFactory& registry, const IThreadPool::Ptr& threadPool) in IEcsInstance()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| D | distributeddb_communicator_test.cpp | 459 auto threadPool = std::make_shared<ThreadPoolTestStub>(); variable
|