Home
last modified time | relevance | path

Searched refs:threadPool_ (Results 1 – 25 of 51) sorted by relevance

123

/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/command_server/
H A Dcommand_server_impl.cpp32 threadPool_ = ThreadPool::Create(commandServerName_, MAX_THREAD_NUM); in CommandServerImpl()
38 threadPool_.reset(); in ~CommandServerImpl()
43 … DP_CHECK_ERROR_RETURN_RET_LOG(threadPool_ == nullptr, DP_NOT_AVAILABLE, "threadPool is nullptr."); in AddCommand()
44 if (threadPool_->Submit([cmd]() {cmd->Do();})) { in AddCommand()
53 … DP_CHECK_ERROR_RETURN_RET_LOG(threadPool_ == nullptr, DP_NOT_AVAILABLE, "threadPool is nullptr."); in AddUrgentCommand()
54 if (threadPool_->Submit([cmd]() {cmd->Do();}, true)) { in AddUrgentCommand()
63 DP_CHECK_ERROR_RETURN_LOG(threadPool_ == nullptr, "threadPool is nullptr."); in SetThreadPriority()
64 threadPool_->SetThreadPoolPriority(priority); in SetThreadPriority()
69 … DP_CHECK_ERROR_RETURN_RET_LOG(threadPool_ == nullptr, DEFAULT_PRIORITY, "threadPool is nullptr."); in GetThreadPriority()
70 return threadPool_->GetThreadPoolPriority(); in GetThreadPriority()
/ohos5.0/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/
H A Dbundle_installer_manager.cpp200 if (threadPool_ == nullptr) { in AddTask()
202 threadPool_ = std::make_shared<ThreadPool>(THREAD_POOL_NAME); in AddTask()
203 threadPool_->Start(THREAD_NUMBER); in AddTask()
204 threadPool_->SetMaxTaskNum(MAX_TASK_NUMBER); in AddTask()
210 threadPool_->AddTask(task); in AddTask()
221 } while (threadPool_ != nullptr && threadPool_->GetCurTaskNum() != 0); in DelayStopThreadPool()
224 if (threadPool_ == nullptr) { in DelayStopThreadPool()
229 threadPool_->Stop(); in DelayStopThreadPool()
230 threadPool_ = nullptr; in DelayStopThreadPool()
237 if (threadPool_ == nullptr) { in GetCurTaskNum()
[all …]
/ohos5.0/base/update/updater/test/unittest/script/
H A Dthreadpool_unittest.cpp42 ThreadPoolUnitTest() : threadPool_(ThreadPool::CreateThreadPool(MAX_TASK_NUMBER)) {} in ThreadPoolUnitTest()
47 threadPool_ = nullptr; in ~ThreadPoolUnitTest()
52 if (threadPool_ == nullptr) { in TestThreadPoolCreate()
75 ThreadPool* threadPool_; member in __anon989601c50110::ThreadPoolUnitTest
/ohos5.0/drivers/peripheral/pin_auth/hdi_service/service/src/
H A Dcollector_impl.cpp30 threadPool_("pin_collector_async") in CollectorImpl()
32 threadPool_.Start(1); in CollectorImpl()
37 threadPool_.Stop(); in ~CollectorImpl()
114 threadPool_.AddTask([this, id = scheduleId]() { in Cancel()
133 threadPool_.AddTask([this, id = scheduleId, message = msg]() { in SendMessage()
169 threadPool_.AddTask([this, id = scheduleId, pinData = data, result = resultCode]() { in SetData()
211 threadPool_.AddTask([this, id = scheduleId, extra = extraInfo, callback = callbackObj]() { in Collect()
H A Dverifier_impl.cpp31 threadPool_("pin_verifier_async") in VerifierImpl()
33 threadPool_.Start(1); in VerifierImpl()
38 threadPool_.Stop(); in ~VerifierImpl()
115 threadPool_.AddTask([this, id = scheduleId]() { in Cancel()
157 threadPool_.AddTask([this, id = scheduleId, role = srcRole, msgIn = msg]() { in SendMessage()
182 threadPool_.AddTask( in Authenticate()
H A Dall_in_one_impl.cpp41 threadPool_("pin_async") in AllInOneImpl()
43 threadPool_.Start(1); in AllInOneImpl()
48 threadPool_.Stop(); in ~AllInOneImpl()
243 threadPool_.AddTask([hdi = pinHdi_, id = templateId]() { in AuthPin()
/ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/
H A Dtask_queue.cpp46 TaskQueue::TaskQueue(const IThreadPool::Ptr& threadPool) : threadPool_(threadPool), isRunningAsync_… in TaskQueue()
52 CORE_ASSERT(threadPool_ != nullptr); in ExecuteAsync()
58 … asyncOperation_ = threadPool_->Push(IThreadPool::ITask::Ptr { new ExecuteAsyncTask(*this) }); in ExecuteAsync()
/ohos5.0/foundation/filemanagement/app_file_service/services/backup_sa/include/module_ipc/
H A Dsa_backup_connection.h99 threadPool_.Start(BConstants::EXTENSION_THREAD_POOL_COUNT); in SABackupConnection()
103 threadPool_.Stop(); in ~SABackupConnection()
127 OHOS::ThreadPool threadPool_; variable
/ohos5.0/base/update/updater/services/script/script_manager/
H A Dscript_managerImpl.cpp65 if (threadPool_) { in ~ScriptManagerImpl()
67 threadPool_ = nullptr; in ~ScriptManagerImpl()
132 …threadPool_ = ThreadPool::CreateThreadPool(threadnum > MAX_THREAD_POOL ? MAX_THREAD_POOL : threadn… in Init()
133 if (threadPool_ == nullptr) { in Init()
224 int32_t threadNumber = threadPool_->GetThreadNumber(); in ExecuteScript()
H A Dscript_manager_impl.h51 ThreadPool *threadPool_ = nullptr; variable
/ohos5.0/foundation/filemanagement/app_file_service/services/backup_sa/include/module_sched/
H A Dsched_scheduler.h81 threadPool_.Start(BConstants::SA_THREAD_POOL_COUNT); in SchedScheduler()
92 OHOS::ThreadPool threadPool_; variable
/ohos5.0/foundation/multimedia/av_codec/test/nativedemo/avdemuxer/server_demo/
H A Dfile_server_demo.cpp40 threadPool_ = std::make_unique<ThreadPool>("fileServerThreadPool"); in StartServer()
41 threadPool_->SetMaxTaskNum(THREAD_POOL_MAX_TASKS); in StartServer()
80 threadPool_->Stop(); in StopServer()
251 threadPool_->AddTask([connFd]() { FileReadFunc(connFd); }); in ServerLoopFunc()
H A Dfile_server_demo.h69 std::unique_ptr<ThreadPool> threadPool_ = nullptr; variable
/ohos5.0/foundation/multimedia/av_codec/test/unittest/common/
H A Dhttp_server_demo.cpp45 threadPool_ = std::make_unique<ThreadPool>("httpServerThreadPool"); in StartServer()
46 threadPool_->SetMaxTaskNum(THREAD_POOL_MAX_TASKS); in StartServer()
85 threadPool_->Stop(); in StopServer()
261 threadPool_->AddTask([connFd]() { FileReadFunc(connFd); }); in ServerLoopFunc()
H A Dhttp_server_demo.h70 std::unique_ptr<ThreadPool> threadPool_ = nullptr; variable
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/task_group/
H A Dbase_task_group.cpp26 threadPool_(threadPool), in BaseTaskGroup()
127 threadPool_->Submit([task = std::move(task)] { task(); }); in DispatchTaskUnlocked()
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/
H A Dtask_registry.cpp25 : name_(name), threadPool_(threadPool), mutex_(), registry_() in TaskRegistry()
47 …ITaskGroup> taskGroup = [delayTask, &name, func = std::move(func), serial, pool = threadPool_] () { in RegisterTaskGroup()
/ohos5.0/foundation/communication/ipc/ipc/native/src/core/source/
H A Dipc_process_skeleton.cpp152 delete threadPool_; in ~IPCProcessSkeleton()
153 threadPool_ = nullptr; in ~IPCProcessSkeleton()
309 if (threadPool_ == nullptr) { in SetMaxWorkThread()
311 if (threadPool_ == nullptr) { in SetMaxWorkThread()
316 threadPool_->UpdateMaxThreadNum(maxThreadNum); in SetMaxWorkThread()
328 if (threadPool_ != nullptr) { in SpawnThread()
339 if (threadPool_ != nullptr) { in OnThreadTerminated()
340 return threadPool_->RemoveThread(threadName); in OnThreadTerminated()
781 if (threadPool_ != nullptr) { in GetSocketIdleThreadNum()
782 return threadPool_->GetSocketIdleThreadNum(); in GetSocketIdleThreadNum()
[all …]
/ohos5.0/foundation/filemanagement/app_file_service/frameworks/native/backup_ext/include/
H A Dext_extension.h71 threadPool_.Start(BConstants::EXTENSION_THREAD_POOL_COUNT);
79 threadPool_.Stop();
300 OHOS::ThreadPool threadPool_;
/ohos5.0/foundation/filemanagement/app_file_service/services/backup_sa/src/module_sched/
H A Dsched_scheduler.cpp86 threadPool_.AddTask(callStart); in Sched()
220 threadPool_.AddTask(tryUnload); in TryUnloadService()
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/command_server/
H A Dcommand_server_impl.h42 std::unique_ptr<ThreadPool> threadPool_; variable
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/task_manager/
H A Dtask_registry.h47 const ThreadPool* threadPool_; variable
/ohos5.0/foundation/filemanagement/app_file_service/services/backup_sa/src/module_ipc/
H A Dsa_backup_connection.cpp187 threadPool_.AddTask([task]() { in CallBackupSA()
211 threadPool_.AddTask([task]() { in CallRestoreSA()
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/task_manager/task_group/
H A Dbase_task_group.h53 const ThreadPool* threadPool_; variable
/ohos5.0/drivers/peripheral/pin_auth/hdi_service/service/inc/
H A Dcollector_impl.h53 OHOS::ThreadPool threadPool_; variable

123