| /ohos5.0/foundation/communication/ipc/ipc/native/test/unittest/common/ |
| H A 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
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/manager/src/ |
| H A 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()
|
| /ohos5.0/foundation/ai/ai_engine/test/common/threadpool/ |
| H A 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
|
| /ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/task_group/ |
| H A D | task_group.cpp | 23 …Group::TaskGroup(const std::string& name, TaskFunc func, bool serial, const ThreadPool* threadPool) in TaskGroup()
|
| H A D | delayed_task_group.cpp | 23 …edTaskGroup::DelayedTaskGroup(const std::string& name, TaskFunc func, const ThreadPool* threadPool) in DelayedTaskGroup()
|
| H A D | base_task_group.cpp | 22 …p::BaseTaskGroup(const std::string& name, TaskFunc func, bool serial, const ThreadPool* threadPool) in BaseTaskGroup()
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | task_queue.cpp | 46 TaskQueue::TaskQueue(const IThreadPool::Ptr& threadPool) : threadPool_(threadPool), isRunningAsync_… in TaskQueue()
|
| H A D | dispatcher_task_queue.cpp | 34 DispatcherTaskQueue::DispatcherTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool… in DispatcherTaskQueue()
|
| H A D | parallel_task_queue.cpp | 82 ParallelTaskQueue::ParallelTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool) {} in ParallelTaskQueue()
|
| /ohos5.0/foundation/ai/ai_engine/services/server/communication_adapter/source/ |
| H A D | client_listener_handler.cpp | 156 ThreadPool *threadPool = ThreadPool::GetInstance(); in StartAsyncProcessThread() local
188 ThreadPool *threadPool = ThreadPool::GetInstance(); in StopAsyncProcessThread() local
|
| /ohos5.0/foundation/ai/ai_engine/services/client/communication_adapter/source/ |
| H A D | sa_client_adapter.cpp | 128 ThreadPool *threadPool = ThreadPool::GetInstance(); in InitAiServer() local
160 ThreadPool *threadPool = ThreadPool::GetInstance(); in CloseAiServer() local
|
| /ohos5.0/foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | engine.cpp | 104 ThreadPool *threadPool = ThreadPool::GetInstance(); in Uninitialize() local
|
| H A D | engine_manager.cpp | 201 ThreadPool *threadPool = ThreadPool::GetInstance(); in CreateEngine() local
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/manager/include/ |
| H A D | ipc_process_skeleton.h | 49 ThreadPool *threadPool; member
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/ |
| H A D | engine.cpp | 130 auto threadPool = threadFactory->CreateThreadPool(threadFactory->GetNumberOfCores()); in CreateEcs() local
137 IEcs::Ptr Engine::CreateEcs(IThreadPool& threadPool) in CreateEcs()
|
| /ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/ |
| H A D | task_registry.cpp | 24 TaskRegistry::TaskRegistry(const std::string& name, const ThreadPool* threadPool) in TaskRegistry()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | runtime_context_impl.cpp | 963 void RuntimeContextImpl::SetThreadPool(const std::shared_ptr<IThreadPool> &threadPool) in SetThreadPool()
978 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in ScheduleTaskByThreadPool() local
989 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in SetTimerByThreadPool() local
1023 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in ModifyTimerByThreadPool() local
1046 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in RemoveTimerByThreadPool() local
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | runtime_config.cpp | 177 void RuntimeConfig::SetThreadPool(const std::shared_ptr<IThreadPool> &threadPool) in SetThreadPool()
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/ecs/ |
| H A D | ecs.cpp | 273 Ecs::Ecs(IClassFactory& registry, const IThreadPool::Ptr& threadPool) in Ecs()
660 IEcs* IEcsInstance(IClassFactory& registry, const IThreadPool::Ptr& threadPool) in IEcsInstance()
|
| /ohos5.0/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/bundle_resource/ |
| H A D | bundle_resource_manager.cpp | 333 std::shared_ptr<ThreadPool> threadPool = std::make_shared<ThreadPool>(THREAD_POOL_NAME); in AddResourceInfosByMap() local
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_test.cpp | 464 auto threadPool = std::make_shared<ThreadPoolTestStub>(); variable
|