Searched refs:executorPool_ (Results 1 - 9 of 9) sorted by relevance
| /foundation/distributeddatamgr/kv_store/frameworks/common/test/ |
| H A D | executor_pool_test.cpp | 37 static std::shared_ptr<ExecutorPool> executorPool_; member in OHOS::Test::ExecutorPoolTest
41 executorPool_ = nullptr; in TearDownTestCase()
46 std::shared_ptr<ExecutorPool> ExecutorPoolTest::executorPool_ = std::make_shared<ExecutorPool>(12, 5); member in OHOS::Test::ExecutorPoolTest
60 auto atTaskId1 = executorPool_->Schedule(expiredTime, [blockData]() { in HWTEST_F()
66 auto atTaskId2 = executorPool_->Schedule(expiredTime, [blockData]() { in HWTEST_F()
85 auto taskId = executorPool_->Schedule( in HWTEST_F()
93 executorPool_->Remove(taskId); in HWTEST_F()
111 auto id = executorPool_->Schedule(task, std::chrono::seconds(0), std::chrono::seconds(LONG_INTERVAL), 10); in HWTEST_F()
118 executorPool_->Remove(id); in HWTEST_F()
135 auto temp = executorPool_ in HWTEST_F()
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/ |
| H A D | store_cache.cpp | 65 if (taskId_ == ExecutorPool::INVALID_TASK_ID && executorPool_ != nullptr) {
in GetStore()
66 taskId_ = executorPool_->Schedule(std::chrono::minutes(INTERVAL), std::bind(&StoreCache::GarbageCollect, this));
in GetStore()
82 if (!stores_.Empty() && executorPool_ != nullptr) {
in GarbageCollect()
84 taskId_ = executorPool_->Schedule(std::chrono::minutes(INTERVAL), std::bind(&StoreCache::GarbageCollect, this));
in GarbageCollect()
92 executorPool_ = executors;
in SetThreadPool()
|
| H A D | store_cache.h | 50 std::shared_ptr<ExecutorPool> executorPool_;
member in OHOS::UDMF::StoreCache
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/permission/ |
| H A D | uri_permission_manager.cpp | 70 if (taskId_ == ExecutorPool::INVALID_TASK_ID && executorPool_ != nullptr) {
in GrantUriPermission()
71 taskId_ = executorPool_->Schedule(
in GrantUriPermission()
106 if (!uriTimeout_.Empty() && executorPool_ != nullptr) {
in RevokeUriPermission()
108 taskId_ = executorPool_->Schedule(
in RevokeUriPermission()
117 executorPool_ = executors;
in SetThreadPool()
|
| H A D | uri_permission_manager.h | 49 std::shared_ptr<ExecutorPool> executorPool_;
member in OHOS::UDMF::UriPermissionManager
|
| /foundation/distributeddatamgr/preferences/frameworks/native/src/ |
| H A D | preferences_enhance_impl.cpp | 190 executorPool_.Execute(std::move(task)); in Put()
224 executorPool_.Execute(std::move(task)); in Delete()
335 executorPool_.Execute(std::move(task)); in Clear()
|
| H A D | preferences_impl.cpp | 153 return (executorPool_.Execute(std::move(task)) == ExecutorPool::INVALID_TASK_ID) ? false : true; in StartLoadFromDisk()
501 executorPool_.Schedule(std::chrono::milliseconds(TASK_EXEC_TIME), std::move(task)); in Flush()
|
| H A D | preferences_base.cpp | 33 ExecutorPool PreferencesBase::executorPool_ = ExecutorPool(1, 0); member in OHOS::NativePreferences::PreferencesBase
|
| /foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| H A D | preferences_base.h | 127 static ExecutorPool executorPool_; member in OHOS::NativePreferences::PreferencesBase
|
Completed in 5 milliseconds