Searched refs:distributedQueue_ (Results 1 – 2 of 2) sorted by relevance
34 distributedQueue_ = std::make_shared<ffrt::queue>("NotificationDistributedMgr"); in DistributedNotificationManager()72 if (distributedQueue_ != nullptr) { in ~DistributedNotificationManager()73 … ffrt::task_handle handler = distributedQueue_->submit_h(std::bind([&]() { callback_ = {}; })); in ~DistributedNotificationManager()74 distributedQueue_->wait(handler); in ~DistributedNotificationManager()81 if (distributedQueue_ != nullptr) { in ResetFfrtQueue()82 distributedQueue_.reset(); in ResetFfrtQueue()151 if (distributedQueue_ == nullptr) { in OnDatabaseInsert()155 distributedQueue_->submit(std::bind([=]() { in OnDatabaseInsert()184 if (distributedQueue_ == nullptr) { in OnDatabaseUpdate()188 ffrt::task_handle handler = distributedQueue_->submit_h(std::bind([=]() { in OnDatabaseUpdate()[all …]
175 std::shared_ptr<ffrt::queue> distributedQueue_ = nullptr; variable