Searched refs:executorPool_ (Results 1 – 9 of 9) sorted by relevance
37 static std::shared_ptr<ExecutorPool> executorPool_; member in OHOS::Test::ExecutorPoolTest41 executorPool_ = nullptr; in TearDownTestCase()60 auto atTaskId1 = executorPool_->Schedule(expiredTime, [blockData]() { in __anon319724040102()66 auto atTaskId2 = executorPool_->Schedule(expiredTime, [blockData]() { in __anon319724040202()85 auto taskId = executorPool_->Schedule(93 executorPool_->Remove(taskId);118 executorPool_->Remove(id);135 auto temp = executorPool_->Schedule(task, expiredTime * 2);138 ASSERT_TRUE(executorPool_->Remove(temp));156 auto temp = executorPool_->Schedule(task, expiredTime * 2);[all …]
65 if (taskId_ == ExecutorPool::INVALID_TASK_ID && executorPool_ != nullptr) { in GetStore()66 …taskId_ = executorPool_->Schedule(std::chrono::minutes(INTERVAL), std::bind(&StoreCache::GarbageCo… in GetStore()82 if (!stores_.Empty() && executorPool_ != nullptr) { in GarbageCollect()84 …taskId_ = executorPool_->Schedule(std::chrono::minutes(INTERVAL), std::bind(&StoreCache::GarbageCo… in GarbageCollect()92 executorPool_ = executors; in SetThreadPool()
50 std::shared_ptr<ExecutorPool> executorPool_; variable
69 if (taskId_ == ExecutorPool::INVALID_TASK_ID && executorPool_ != nullptr) { in GrantUriPermission()70 taskId_ = executorPool_->Schedule( in GrantUriPermission()105 if (!uriTimeout_.Empty() && executorPool_ != nullptr) { in RevokeUriPermission()107 taskId_ = executorPool_->Schedule( in RevokeUriPermission()116 executorPool_ = executors; in SetThreadPool()
48 std::shared_ptr<ExecutorPool> executorPool_; variable
139 executorPool_.Execute(std::move(task)); in Put()166 executorPool_.Execute(std::move(task)); in Delete()267 executorPool_.Execute(std::move(task)); in Clear()
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()
33 ExecutorPool PreferencesBase::executorPool_ = ExecutorPool(1, 0); member in OHOS::NativePreferences::PreferencesBase
127 static ExecutorPool executorPool_; variable