| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/common/test/ |
| H A D | pool_test.cpp | 78 ret = pool_.Get();
82 ret = pool_.Get();
86 ret = pool_.Get();
104 ret = pool_.Get();
137 pool_.Idle(ret);
154 pool_.Idle(ret);
176 pool_.Idle(ret);
210 pool_.Idle(ret);
233 pool_.Idle(ret);
250 pool_.Idle(ret);
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | task_executor.cpp | 21 pool_ = nullptr; in ~TaskExecutor()
32 if (pool_ == nullptr) { in Execute()
35 if (pool_ == nullptr) { in Execute()
43 if (pool_ == nullptr) { in Schedule()
46 if (pool_ == nullptr) { in Schedule()
54 if (pool_ == nullptr) { in Remove()
57 return pool_->Remove(taskId, wait); in Remove()
62 if (pool_ == nullptr) { in Reset()
71 if (pool_ == nullptr) { in SetExecutors()
72 pool_ = std::move(executors); in SetExecutors()
[all …]
|
| /ohos5.0/base/useriam/face_auth/services_ex/src/ |
| H A D | thread_handler_impl.cpp | 43 OHOS::ThreadPool pool_; member in OHOS::UserIam::FaceAuth::ThreadHandlerImpl
48 pool_.Start(1); in ThreadHandlerImpl()
53 pool_.Stop(); in ~ThreadHandlerImpl()
58 pool_.AddTask(task); in PostTask()
68 pool_.AddTask(task); in EnsureTask()
69 pool_.AddTask(callback); in EnsureTask()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | delay_notify.cpp | 20 DelayNotify::DelayNotify() : pauseCount_(0), task_(nullptr), pool_(nullptr) in DelayNotify()
26 if (pool_ == nullptr) { in ~DelayNotify()
30 pool_->Remove(delaySyncTaskId_); in ~DelayNotify()
64 if (pool_ != nullptr) { in SetExecutorPool()
67 pool_ = pool; in SetExecutorPool()
84 if (pool_ == nullptr) { in StartTimer()
89 delaySyncTaskId_ = pool_->Schedule(std::chrono::milliseconds(autoSyncInterval_), in StartTimer()
93 pool_->Reset(delaySyncTaskId_, std::chrono::milliseconds(autoSyncInterval_)); in StartTimer()
124 if (pool_ != nullptr) { in StopTimer()
125 pool_->Remove(delaySyncTaskId_); in StopTimer()
|
| H A D | task_executor.cpp | 21 pool_ = std::make_shared<ExecutorPool>(MAX_THREADS, MIN_THREADS); in TaskExecutor()
26 pool_ = nullptr; in ~TaskExecutor()
38 return pool_; in GetExecutor()
44 pool_ = executor; in SetExecutor()
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/scrollable/ |
| H A D | scrollable_item_pool.cpp | 35 auto it = pool_.find(tag); in Allocate()
36 if (it == pool_.end() || it->second.empty()) { in Allocate()
54 auto it = pool_.find(tag); in Deallocate()
55 if (it == pool_.end()) { in Deallocate()
56 pool_[tag] = { obj }; in Deallocate()
|
| H A D | scrollable_item_pool.h | 38 std::unordered_map<std::string, std::vector<ScrollableItem*>> pool_; variable
|
| /ohos5.0/base/update/sys_installer/services/module_update/src/ |
| H A D | module_update_task.cpp | 73 pool_.AddTask([hmpName] { in AddTask()
83 return pool_.GetCurTaskNum(); in GetCurTaskNum()
88 pool_.Stop(); in Stop()
93 pool_.Start(1); in Start()
94 pool_.SetMaxTaskNum(MAX_TASK_NUM); in Start()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/src/ |
| H A D | task_executor.cpp | 19 TaskExecutor::TaskExecutor():pool_(nullptr) in TaskExecutor()
25 pool_ = nullptr; in ~TaskExecutor()
36 return pool_; in GetExecutor()
41 pool_ = executor; in SetExecutor()
|
| /ohos5.0/base/security/security_guard/frameworks/common/task_handler/src/ |
| H A D | task_handler.cpp | 31 pool_.Start(THREAD_NUMS); in TaskHandler()
32 pool_.SetMaxTaskNum(MAX_TASK_NUMS); in TaskHandler()
40 pool_.Stop(); in ~TaskHandler()
46 pool_.AddTask(task); in AddTask()
|
| /ohos5.0/foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| H A D | executor_pool.h | 47 : pool_(max, min), delayTasks_(InnerTask(), NextTimer), taskId_(INVALID_TASK_ID) in ExecutorPool()
70 pool_.Clean([](std::shared_ptr<Executor> executor) { in ~ExecutorPool()
149 auto executor = pool_.Get(); in Execute()
156 pool_.Idle(exe); in Execute()
160 return pool_.Release(exe, force); in Execute()
178 scheduler_ = pool_.Get(true); in Schedule()
187 pool_.Idle(exe); in Schedule()
191 return pool_.Release(exe, force); in Schedule()
217 Pool<Executor> pool_; variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | executor_pool.h | 44 : pool_(max, min), delayTasks_(InnerTask(), NextTimer), taskId_(INVALID_TASK_ID) in ExecutorPool()
67 pool_.Clean([](std::shared_ptr<Executor> executor) { in ~ExecutorPool()
145 auto executor = pool_.Get(); in Execute()
152 pool_.Idle(exe); in Execute()
156 return pool_.Release(exe, force); in Execute()
174 scheduler_ = pool_.Get(true); in Schedule()
183 pool_.Idle(exe); in Schedule()
187 return pool_.Release(exe, force); in Schedule()
213 Pool<Executor> pool_; variable
|
| /ohos5.0/base/useriam/user_auth_framework/services/base/src/ |
| H A D | thread_handler_impl.cpp | 33 ThreadHandlerImpl::ThreadHandlerImpl(std::string name, bool canSuspend) : pool_(name), canSuspend_(… in ThreadHandlerImpl()
35 pool_.Start(1); in ThreadHandlerImpl()
40 pool_.Stop(); in ~ThreadHandlerImpl()
50 pool_.AddTask(task); in PostTask()
|
| /ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/ |
| H A D | task_manager.cpp | 28 pool_(nullptr), in TaskManager()
41 pool_ = ThreadPool::Create(name_, numThreads_); in Initialize()
42 taskRegistry_ = std::make_unique<TaskRegistry>(name_, pool_.get()); in Initialize()
67 pool_.reset(); in ~TaskManager()
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/core/components/custom_paint/ |
| H A D | custom_paint_component.h | 168 pool_ = AceType::MakeRefPtr<CanvasTaskPool>(); in CustomPaintComponent()
199 if (pool_) { in SetOnReadyEvent()
201 pool_->SetOnReadyEvent(onReadyEvent); in SetOnReadyEvent()
207 return pool_; in GetTaskPool()
214 RefPtr<CanvasTaskPool> pool_; variable
|
| H A D | render_custom_paint.cpp | 49 pool_ = taskPool; in Update()
52 pool_->SetPushToRenderNodeFunc([weak = AceType::WeakClaim(this)](const TaskFunc& taskFunc) { in Update()
|
| /ohos5.0/foundation/multimedia/av_codec/services/media_engine/plugins/source/ |
| H A D | data_stream_source_plugin.cpp | 69 pool_ = std::make_shared<AVSharedMemoryPool>("pool"); in DataStreamSourcePlugin()
121 pool_->Init(InitOption); in InitPool()
122 pool_->GetName(); in InitPool()
123 pool_->Reset(); in InitPool()
128 return pool_->AcquireMemory(MEM_SIZE); // 10240 in GetMemory()
133 pool_->Reset(); in ResetPool()
|
| /ohos5.0/foundation/multimedia/media_foundation/engine/plugin/plugins/source/std_stream_source/ |
| H A D | std_stream_source_plugin.cpp | 51 pool_ = std::make_shared<AVSharedMemoryPool>("pool"); in StdStreamSourcePlugin()
148 pool_->Init(InitOption); in InitPool()
153 return pool_->AcquireMemory(MEM_SIZE); // 10240 in GetMemory()
158 pool_->Reset(); in ResetPool()
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/core/components/xcomponent/ |
| H A D | xcomponent_component.cpp | 37 pool_ = AceType::MakeRefPtr<XComponentTaskPool>(); in XComponentComponent()
38 pool_->component_ = AceType::WeakClaim(this); in XComponentComponent()
|
| H A D | xcomponent_component.h | 180 return pool_; in GetTaskPool()
261 RefPtr<XComponentTaskPool> pool_; variable
|
| /ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/ |
| H A D | datashare_connection.cpp | 85 if (pool_ == nullptr) { in OnAbilityDisconnectDone()
87 if (pool_ == nullptr) { in OnAbilityDisconnectDone()
88 pool_ = std::make_shared<ExecutorPool>(MAX_THREADS, MIN_THREADS); in OnAbilityDisconnectDone()
133 auto taskid = pool_->Schedule(delay, [uri, self]() { in DelayConnectExtAbility()
|
| /ohos5.0/base/security/security_guard/frameworks/common/task_handler/include/ |
| H A D | task_handler.h | 35 OHOS::ThreadPool pool_;
|
| /ohos5.0/base/useriam/user_auth_framework/services/base/inc/ |
| H A D | thread_handler_impl.h | 38 OHOS::ThreadPool pool_;
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A D | task_executor.h | 36 std::shared_ptr<ExecutorPool> pool_; variable
|
| /ohos5.0/base/update/sys_installer/services/module_update/include/ |
| H A D | module_update_task.h | 52 OHOS::ThreadPool pool_; variable
|