| /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
66 pthread_mutex_lock(&threadPool->lock); in ThreadContextDestructor()
68 ++threadPool->idleThreadNum; in ThreadContextDestructor()
70 ++threadPool->idleSocketThreadNum; in ThreadContextDestructor()
112 if (threadPool == NULL) { in InitThreadPool()
123 return threadPool; in InitThreadPool()
128 if (threadPool == NULL) { in DeinitThreadPool()
133 free(threadPool); in DeinitThreadPool()
134 threadPool = NULL; in DeinitThreadPool()
176 --threadPool->idleThreadNum; in SpawnNewThread()
[all …]
|
| H A D | ipc_process_skeleton.c | 42 DeinitThreadPool(temp->threadPool); in DeleteIpcSkeleton()
53 temp->threadPool = InitThreadPool(SET_MAX_THREADS_DEFAULT); in IpcProcessSkeleton()
54 if (temp->threadPool == NULL) { in IpcProcessSkeleton()
70 SpawnNewThread(temp->threadPool, SPAWN_ACTIVE, IF_PROT_BINDER); in IpcProcessSkeleton()
103 if (g_ipcSkeleton == NULL || g_ipcSkeleton->threadPool == NULL) { in SpawnThread()
107 return SpawnNewThread(g_ipcSkeleton->threadPool, policy, proto); in SpawnThread()
112 if (g_ipcSkeleton == NULL || g_ipcSkeleton->threadPool == NULL) { in SetMaxWorkThread()
116 UpdateMaxThreadNum(g_ipcSkeleton->threadPool, maxThreadNum); in SetMaxWorkThread()
|
| /ohos5.0/foundation/communication/ipc/ipc/native/test/unittest/common/ |
| H A D | ipc_thread_pool_unittest.cpp | 55 IPCWorkThreadPool threadPool(1); variable
66 threadPool.threads_.clear();
77 IPCWorkThreadPool threadPool(1); variable
87 threadPool.threads_.clear();
97 IPCWorkThreadPool threadPool(1); variable
107 threadPool.threads_.clear();
117 IPCWorkThreadPool threadPool(1); variable
125 threadPool.threads_.clear();
135 IPCWorkThreadPool threadPool(1); variable
150 IPCWorkThreadPool threadPool(1); variable
[all …]
|
| /ohos5.0/foundation/ai/ai_engine/test/common/threadpool/ |
| H A D | thread_pool_test.cpp | 165 ASSERT_EQ(threadPool->getStackSize(), 0);
166 threadPool->SetStackSize(SIZE);
167 ASSERT_EQ(threadPool->getStackSize(), SIZE);
168 threadPool->SetStackSize(SIZE_MIN);
182 ASSERT_NE(threadPool, nullptr);
198 ASSERT_NE(threadPool, nullptr);
200 threadPool->Push(oneThread);
218 ASSERT_NE(threadPool, nullptr);
222 threadList[i] = threadPool->Pop();
227 threadPool->Push(threadList[i]);
[all …]
|
| /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
157 CHK_RET(threadPool == nullptr, RETCODE_OUT_OF_MEMORY); in StartAsyncProcessThread()
162 asyncProcessThread_ = threadPool->Pop(); in StartAsyncProcessThread()
167 threadPool->Push(asyncProcessThread_); in StartAsyncProcessThread()
174 threadPool->Push(asyncProcessThread_); in StartAsyncProcessThread()
188 ThreadPool *threadPool = ThreadPool::GetInstance(); in StopAsyncProcessThread() local
189 CHK_RET_NONE(threadPool == nullptr); in StopAsyncProcessThread()
190 threadPool->Push(asyncProcessThread_); in StopAsyncProcessThread()
|
| /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
129 CHK_RET(threadPool == nullptr, RETCODE_OUT_OF_MEMORY); in InitAiServer()
131 connectMgrThread_ = threadPool->Pop(); in InitAiServer()
136 threadPool->Push(connectMgrThread_); in InitAiServer()
144 threadPool->Push(connectMgrThread_); in InitAiServer()
160 ThreadPool *threadPool = ThreadPool::GetInstance(); in CloseAiServer() local
161 CHK_RET(threadPool == nullptr, RETCODE_OUT_OF_MEMORY); in CloseAiServer()
162 threadPool->Push(connectMgrThread_); in CloseAiServer()
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | task_queue_factory.h | 30 …IDispatcherTaskQueue::Ptr CreateDispatcherTaskQueue(const IThreadPool::Ptr& threadPool) const over… in CORE_BEGIN_NAMESPACE()
31 …IParallelTaskQueue::Ptr CreateParallelTaskQueue(const IThreadPool::Ptr& threadPool) const override; in CORE_BEGIN_NAMESPACE()
32 …ISequentialTaskQueue::Ptr CreateSequentialTaskQueue(const IThreadPool::Ptr& threadPool) const over… in CORE_BEGIN_NAMESPACE()
|
| H A D | task_queue_factory.cpp | 411 …askQueue::Ptr TaskQueueFactory::CreateDispatcherTaskQueue(const IThreadPool::Ptr& threadPool) const in CreateDispatcherTaskQueue()
413 return IDispatcherTaskQueue::Ptr { make_unique<DispatcherImpl>(threadPool).release() }; in CreateDispatcherTaskQueue()
416 …lTaskQueue::Ptr TaskQueueFactory::CreateParallelTaskQueue(const IThreadPool::Ptr& threadPool) const in CreateParallelTaskQueue()
418 return IParallelTaskQueue::Ptr { make_unique<ParallelImpl>(threadPool).release() }; in CreateParallelTaskQueue()
421 …askQueue::Ptr TaskQueueFactory::CreateSequentialTaskQueue(const IThreadPool::Ptr& threadPool) const in CreateSequentialTaskQueue()
423 return ISequentialTaskQueue::Ptr { make_unique<SequentialImpl>(threadPool).release() }; in CreateSequentialTaskQueue()
|
| H A D | task_queue.cpp | 46 TaskQueue::TaskQueue(const IThreadPool::Ptr& threadPool) : threadPool_(threadPool), isRunningAsync_… in TaskQueue() argument
|
| H A D | sequential_task_queue.cpp | 31 SequentialTaskQueue::SequentialTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool… in CORE_BEGIN_NAMESPACE()
|
| H A D | dispatcher_task_queue.cpp | 34 DispatcherTaskQueue::DispatcherTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool… in DispatcherTaskQueue() argument
|
| H A D | parallel_task_queue.cpp | 82 ParallelTaskQueue::ParallelTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool) {} in ParallelTaskQueue() argument
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/manager/include/ |
| H A D | ipc_thread_pool.h | 59 void DeinitThreadPool(ThreadPool *threadPool);
61 int32_t SpawnNewThread(ThreadPool *threadPool, int32_t policy, int32_t proto);
67 void UpdateMaxThreadNum(ThreadPool *threadPool, int32_t maxThreadNum);
|
| /ohos5.0/foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | engine_manager.cpp | 201 ThreadPool *threadPool = ThreadPool::GetInstance(); in CreateEngine() local
202 CHK_RET(threadPool == nullptr, RETCODE_OUT_OF_MEMORY); in CreateEngine()
203 std::shared_ptr<Thread> thread = threadPool->Pop(); in CreateEngine()
214 threadPool->Push(thread); in CreateEngine()
223 threadPool->Push(thread); in CreateEngine()
232 threadPool->Push(thread); in CreateEngine()
|
| H A D | engine.cpp | 104 ThreadPool *threadPool = ThreadPool::GetInstance(); in Uninitialize() local
105 CHK_RET_NONE(threadPool == nullptr); in Uninitialize()
106 threadPool->Push(thread_); in Uninitialize()
|
| /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() argument
24 : BaseTaskGroup(name, std::move(func), serial, threadPool) in TaskGroup()
|
| H A D | delayed_task_group.cpp | 23 …edTaskGroup::DelayedTaskGroup(const std::string& name, TaskFunc func, const ThreadPool* threadPool) in DelayedTaskGroup() argument
24 …: BaseTaskGroup(name, std::move(func), true, threadPool), mutex_(), timeBroker_(nullptr), paramMap… 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() argument
26 threadPool_(threadPool), in BaseTaskGroup()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | runtime_context_impl.cpp | 966 threadPool_ = threadPool; in SetThreadPool()
978 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in ScheduleTaskByThreadPool() local
979 if (threadPool == nullptr) { in ScheduleTaskByThreadPool()
982 (void)threadPool->Execute(task); in ScheduleTaskByThreadPool()
989 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in SetTimerByThreadPool() local
990 if (threadPool == nullptr) { in SetTimerByThreadPool()
1023 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in ModifyTimerByThreadPool() local
1024 if (threadPool == nullptr) { in ModifyTimerByThreadPool()
1037 TaskId ret = threadPool->Reset(taskId, duration); in ModifyTimerByThreadPool()
1046 std::shared_ptr<IThreadPool> threadPool = GetThreadPool(); in RemoveTimerByThreadPool() local
[all …]
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/api/core/threading/ |
| H A D | intf_thread_pool.h | 228 …virtual IDispatcherTaskQueue::Ptr CreateDispatcherTaskQueue(const IThreadPool::Ptr& threadPool) co…
234 …virtual IParallelTaskQueue::Ptr CreateParallelTaskQueue(const IThreadPool::Ptr& threadPool) const …
240 …virtual ISequentialTaskQueue::Ptr CreateSequentialTaskQueue(const IThreadPool::Ptr& threadPool) co…
|
| /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
334 if (threadPool == nullptr) { in AddResourceInfosByMap()
338 threadPool->Start(MAX_TASK_NUMBER); in AddResourceInfosByMap()
339 threadPool->SetMaxTaskNum(MAX_TASK_NUMBER); in AddResourceInfosByMap()
344 threadPool->Stop(); in AddResourceInfosByMap()
358 threadPool->AddTask(task); in AddResourceInfosByMap()
360 while (threadPool->GetCurTaskNum() > 0) { in AddResourceInfosByMap()
363 threadPool->Stop(); in AddResourceInfosByMap()
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/ |
| H A D | engine.cpp | 130 auto threadPool = threadFactory->CreateThreadPool(threadFactory->GetNumberOfCores()); in CreateEcs() local
131 return IEcs::Ptr { IEcsInstance(*this, threadPool) }; in CreateEcs()
137 IEcs::Ptr Engine::CreateEcs(IThreadPool& threadPool) in CreateEcs() argument
139 return IEcs::Ptr { IEcsInstance(*this, IThreadPool::Ptr { &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() argument
25 : name_(name), threadPool_(threadPool), mutex_(), registry_() in TaskRegistry()
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/ecs/ |
| H A D | ecs.cpp | 53 Ecs(IClassFactory&, const IThreadPool::Ptr& threadPool);
273 Ecs::Ecs(IClassFactory& registry, const IThreadPool::Ptr& threadPool) in Ecs() argument
274 : threadPool_(threadPool), pluginRegistry_(registry) in Ecs()
660 IEcs* IEcsInstance(IClassFactory& registry, const IThreadPool::Ptr& threadPool) in IEcsInstance() argument
662 return new Ecs(registry, threadPool); in IEcsInstance()
|
| /ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/task_manager/task_group/ |
| H A D | task_group.h | 26 TaskGroup(const std::string& name, TaskFunc func, bool serial, const ThreadPool* threadPool);
|