Home
last modified time | relevance | path

Searched refs:queue_ (Results 1 – 25 of 145) sorted by relevance

123456

/ohos5.0/foundation/resourceschedule/ffrt/src/queue/
H A Dqueue_handler.cpp53 queue_ = CreateQueue(type, attr); in QueueHandler()
116 return queue_->Pull(); in PickUpTask()
146 int ret = queue_->Push(task); in Submit()
166 queue_->Push(task); in Submit()
175 queue_->Remove(); in Cancel()
182 queue_->Stop(); in CancelAndWait()
192 int ret = queue_->Remove(name); in Cancel()
210 int ret = queue_->Remove(task); in Cancel()
261 if (!queue_->IsOnLoop()) { in Dispatch()
271 QueueTask* task = queue_->Pull(); in Deliver()
[all …]
H A Dqueue_handler.h55 return !isUsed_.load() && (queue_->GetQueueType() == ffrt_queue_concurrent in IsValidForLoop()
56 || queue_->GetQueueType() == ffrt_queue_eventhandler_interactive); in IsValidForLoop()
66 FFRT_COND_DO_ERR((queue_ == nullptr), return 0, "queue construct failed"); in GetQueueId()
67 return queue_->GetQueueId(); in GetQueueId()
77 …FFRT_COND_DO_ERR((queue_ == nullptr), return false, "[queueId=%u] constructed failed", GetQueueId(… in HasTask()
78 return queue_->HasTask(name); in HasTask()
83 …FFRT_COND_DO_ERR((queue_ == nullptr), return false, "[queueId=%u] constructed failed", GetQueueId(… in GetTaskCnt()
84 return queue_->GetMapSize(); in GetTaskCnt()
96 return queue_; in GetQueue()
115 std::unique_ptr<BaseQueue> queue_ = nullptr; variable
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dmessage_queue.cpp23 queue_.push(data); in EnQueue()
30 if (queue_.empty()) { in DeQueue()
36 queue_.pop(); in DeQueue()
46 return queue_.empty(); in IsEmpty()
56 queue_.pop(); in Clear()
64 queue_.push({id, data}); in Push()
70 queue_.pop(); in Pop()
76 return queue_.front(); in Front()
82 return queue_.empty(); in IsEmpty()
88 while (!queue_.empty()) { in Clear()
[all …]
/ohos5.0/foundation/ai/intelligent_voice_framework/utils/
H A Dqueue_util.h52 while (queue_.size() >= capacity_) {
58 queue_.push(element);
67 while (queue_.size() >= capacity_) {
73 queue_.push(std::move(element));
82 while (queue_.empty()) { in Pop()
88 queue_.pop(); in Pop()
97 while (queue_.empty()) { in PopUntilTimeout()
107 queue_.pop(); in PopUntilTimeout()
133 while (!queue_.empty()) { in ClearQueue()
134 queue_.pop(); in ClearQueue()
[all …]
/ohos5.0/base/telephony/core_service/utils/common/src/
H A Dtel_event_handler.cpp70 if (!queue_) { in SendEvent()
74 queue_->Submit(event, priority); in SendEvent()
86 if (!queue_) { in SendExecuteNowEvent()
90 queue_->Submit(event, Priority::IMMEDIATE); in SendExecuteNowEvent()
96 if (!queue_) { in RemoveEvent()
100 queue_->RemoveEvent(innerEventId); in RemoveEvent()
105 if (!queue_) { in HasInnerEvent()
109 return queue_->HasInnerEvent(innerEventId); in HasInnerEvent()
114 if (!queue_) { in RemoveAllEvents()
118 queue_->RemoveAllEvents(); in RemoveAllEvents()
[all …]
/ohos5.0/foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/event/
H A Dwifi_direct_event_sender.h23 explicit WifiDirectEventSender(WifiDirectEventQueue *queue) : queue_(queue) {} in WifiDirectEventSender()
28 if (queue_ != nullptr) { in Send()
29 queue_->Push(content); in Send()
35 if (queue_ != nullptr) { in ProcessUnHandle()
36 queue_->Process(handler); in ProcessUnHandle()
42 if (queue_ != nullptr) { in Clear()
43 queue_->Clear(); in Clear()
48 WifiDirectEventQueue *queue_;
H A Dwifi_direct_event_queue.h32 queue_.push_back(std::make_shared<WifiDirectEventWrapper<Content>>(content)); in Push()
39 c_.wait(lk, [&] { return !queue_.empty(); }); in WaitAndPop()
40 auto res = queue_.front(); in WaitAndPop()
41 queue_.pop_front(); in WaitAndPop()
49 for (auto it = queue_.rbegin(); it != queue_.rend(); it++) { in Process()
57 queue_.clear(); in Clear()
63 std::deque<std::shared_ptr<WifiDirectEventBase>> queue_; variable
/ohos5.0/foundation/multimedia/camera_framework/services/camera_service/include/
H A Dlru_map.h58 queue_.clear(); in Clear()
64 auto it = std::find_if(queue_.begin(), queue_.end(), [&key](const std::pair<K, V>& pair) { in MoveNodeToLast()
67 if (it != queue_.end()) { in MoveNodeToLast()
68 queue_.erase(it); in MoveNodeToLast()
71 queue_.push_back(entry); in MoveNodeToLast()
72 while (queue_.size() > MAX_CACHE_ITEMS) { in MoveNodeToLast()
73 std::pair<K, V> &pair = queue_.front(); in MoveNodeToLast()
75 queue_.pop_front(); in MoveNodeToLast()
82 std::deque<std::pair<K, V>> queue_; variable
/ohos5.0/foundation/multimodalinput/input/intention/common/channel/include/
H A Dchannel.h177 std::deque<Event> queue_; variable
199 queue_.clear(); in Disable()
213 queue_.push_back(event); in Send()
224 if (queue_.empty()) { in Peek()
226 return !queue_.empty(); in Peek()
229 return queue_.front(); in Peek()
236 if (queue_.empty()) { in Pop()
241 queue_.pop_front(); in Pop()
248 if (queue_.empty()) { in Receive()
253 Event event = queue_.front(); in Receive()
[all …]
/ohos5.0/base/msdp/device_status/intention/common/channel/include/
H A Dchannel.h177 std::deque<Event> queue_; variable
199 queue_.clear(); in Disable()
213 queue_.push_back(event); in Send()
224 if (queue_.empty()) { in Peek()
226 return !queue_.empty(); in Peek()
229 return queue_.front(); in Peek()
236 if (queue_.empty()) { in Pop()
241 queue_.pop_front(); in Pop()
248 if (queue_.empty()) { in Receive()
253 Event event = queue_.front(); in Receive()
[all …]
/ohos5.0/foundation/filemanagement/dfs_service/utils/system/include/
H A Ddfsu_thread_safe_queue.h49 queue_.emplace_back(std::move(pt)); in Push()
61 queue_.emplace_front(std::move(pt)); in PushFront()
69 cv_.wait(lock, [&] { return !queue_.empty() || halted; }); in WaitAndPop()
70 if (halted && queue_.empty()) { in WaitAndPop()
74 auto res = std::move(queue_.front()); in WaitAndPop()
75 queue_.pop_front(); in WaitAndPop()
82 std::for_each(queue_.begin(), queue_.end(), executor); in ForEach()
93 std::deque<std::unique_ptr<T>> queue_;
/ohos5.0/base/notification/eventhandler/frameworks/eventhandler/src/
H A Devent_runner.cpp303 queue_->RemoveAll(); in ~EventRunnerImpl()
336 queue_->Prepare(); in Run()
365 queue_->Finish(); in Stop()
388 for (auto event = queue_->GetEvent(); event; event = queue_->GetEvent()) { in DefaultModeLoop()
560 sp->queue_->SetIoWaiter(false); in Create()
583 sp->queue_->SetIoWaiter(false); in Create()
740 if (queue_ == nullptr) { in Dump()
747 queue_->Dump(dumper); in Dump()
756 if (queue_ == nullptr) { in DumpRunnerInfo()
788 return runner->queue_; in GetCurrentEventQueue()
[all …]
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/util/
H A Dfixed_queue.h78 std::queue<T> queue_ {};
97 while (!queue_.empty()) { in ~FixedQueue()
98 queue_.pop(); in ~FixedQueue()
110 queue_.push(std::move(record)); in TryPush()
123 queue_.push(std::move(record)); in Push()
136 record = std::move(queue_.front()); in TryPop()
137 queue_.pop(); in TryPop()
150 record = std::move(queue_.front()); in Pop()
151 queue_.pop(); in Pop()
/ohos5.0/foundation/systemabilitymgr/samgr/services/samgr/native/source/
H A Dffrt_handler.cpp31 queue_ = std::make_shared<queue>(name.c_str()); in FFRTHandler()
38 if (queue_ != nullptr && iter->second != nullptr) { in CleanFfrt()
39 auto ret = queue_->cancel(iter->second); in CleanFfrt()
47 if (queue_ != nullptr) { in CleanFfrt()
48 queue_.reset(); in CleanFfrt()
54 queue_ = std::make_shared<queue>(name.c_str()); in SetFfrt()
59 task_handle handler = queue_->submit_h(func); in PostTask()
73 task_handle handler = queue_->submit_h(func, task_attr().delay(delayTime * CONVERSION_FACTOR)); in PostTask()
88 task_handle handler = queue_->submit_h(func, task_attr().delay(delayTime * CONVERSION_FACTOR)); in PostTask()
106 auto ret = queue_->cancel(item->second); in RemoveTask()
/ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/
H A Ddispatcher_impl.cpp27 DispatcherImpl::DispatcherImpl(const IThreadPool::Ptr& threads) : queue_(threads) {} in DispatcherImpl()
31 return queue_.CollectFinishedTasks(); in CollectFinishedTasks()
36 queue_.Submit(taskIdentifier, move(task)); in Submit()
41 queue_.SubmitAfter(afterIdentifier, taskIdentifier, move(task)); in SubmitAfter()
47 queue_.SubmitAfter(afterIdentifiers, taskIdentifier, move(task)); in SubmitAfter()
52 queue_.Execute(); in Execute()
57 queue_.Clear(); in Clear()
H A Dparallel_impl.cpp27 ParallelImpl::ParallelImpl(const IThreadPool::Ptr& threads) : queue_(threads) {} in ParallelImpl()
31 queue_.Submit(taskIdentifier, move(task)); in Submit()
36 queue_.SubmitAfter(afterIdentifier, taskIdentifier, move(task)); in SubmitAfter()
42 queue_.SubmitAfter(afterIdentifiers, taskIdentifier, move(task)); in SubmitAfter()
47 queue_.Execute(); in Execute()
52 queue_.Clear(); in Clear()
H A Dsequential_impl.cpp27 SequentialImpl::SequentialImpl(const IThreadPool::Ptr& threads) : queue_(threads) {} in SequentialImpl()
31 queue_.Submit(taskIdentifier, move(task)); in Submit()
36 queue_.SubmitAfter(afterIdentifier, taskIdentifier, move(task)); in SubmitAfter()
42 queue_.SubmitAfter(afterIdentifiers, taskIdentifier, move(task)); in SubmitAfter()
47 queue_.Execute(); in Execute()
52 queue_.Clear(); in Clear()
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/frame_analyzer/export/
H A Dring_queue.h43 queue_[back_++] = t; in Push()
49 return queue_[retPoint]; in Push()
158 return Iter(&queue_, front_); in begin()
163 return Iter(&queue_, back_); in end()
169 return RevertIter(&queue_, (back_ + cap) % realcap); in rbegin()
171 return RevertIter(&queue_, 0); in rbegin()
178 return RevertIter(&queue_, (front_ + cap) % realcap); in rend()
180 return RevertIter(&queue_, 0); in rend()
185 Array queue_;
/ohos5.0/foundation/distributedhardware/device_manager/utils/src/timer/
H A Ddm_timer.cpp32 if (queue_ != nullptr) { in DmTimer()
36 queue_ = std::make_shared<ffrt::queue>(TIMER_TASK); in DmTimer()
51 CHECK_NULL_RETURN(queue_, ERR_DM_POINT_NULL); in StartTimer()
56 …ffrt::task_handle handle = queue_->submit_h(taskFunc, ffrt::task_attr().delay(timeOut * MICROSECON… in StartTimer()
78 if (item->second != nullptr && queue_ != nullptr) { in DeleteTimer()
79 int32_t ret = queue_->cancel(item->second); in DeleteTimer()
93 if (name.second != nullptr && queue_ != nullptr) { in DeleteAll()
94 int32_t ret = queue_->cancel(name.second); in DeleteAll()
/ohos5.0/foundation/arkui/ace_engine/frameworks/base/thread/
H A Dsem_queue.h30 if (queue_.empty()) { in PopFront()
32 return !queue_.empty(); in PopFront()
36 t = queue_.front(); in PopFront()
37 queue_.pop(); in PopFront()
43 queue_.push(std::move(t)); in Push()
48 std::queue<T> queue_;
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dmessage_queue.h29 queue_.push(data); in EnQueue()
35 if (queue_.empty()) { in DeQueue()
39 auto data = queue_.front(); in DeQueue()
40 queue_.pop(); in DeQueue()
47 return queue_.empty(); in IsEmpty()
52 std::queue<MessageDataType> queue_; variable
/ohos5.0/foundation/ai/ai_engine/services/common/platform/queuepool/
H A Dqueue.inl21 AIE_NEW(queue_, QueueNode[maxQueueSize]);
22 CHK_RET_NONE(queue_ == nullptr);
27 AIE_DELETE_ARRAY(queue_);
47 queue_[pushPos].node = msgBlock;
48 queue_[pushPos].empty = false;
62 if (queue_[popPos].empty) {
69 msgBlock = queue_[popPos].node;
70 queue_[popPos].empty = true;
90 queue_[i].empty = true;
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/platform/darwin/
H A Drs_vsync_client_darwin.h34 if (queue_.empty()) { in PopFront()
36 return !queue_.empty(); in PopFront()
40 t = queue_.front(); in PopFront()
41 queue_.pop(); in PopFront()
47 queue_.push(std::move(t)); in Push()
52 std::queue<T> queue_;
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/platform/windows/
H A Drs_vsync_client_windows.h34 if (queue_.empty()) { in PopFront()
36 return !queue_.empty(); in PopFront()
40 t = queue_.front(); in PopFront()
41 queue_.pop(); in PopFront()
47 queue_.push(std::move(t)); in Push()
52 std::queue<T> queue_;
/ohos5.0/foundation/communication/netstack/utils/http_over_curl/include/
H A Dthread_safe_storage.h38 std::queue<T> queue_; variable
50 queue_.push(element); in Push()
59 while (!queue_.empty()) { in Flush()
60 elementsToReturn.push_back(std::move(queue_.front())); in Flush()
61 queue_.pop(); in Flush()
71 return queue_.empty(); in IsEmpty()

123456