Home
last modified time | relevance | path

Searched refs:queue_ (Results 1 - 25 of 93) sorted by relevance

1234

/foundation/CastEngine/castengine_wifi_display/services/utils/
H A Ddata_queue.cpp39 if (queue_.size() < sizeMax_) { in Push()
40 queue_.push(std::move(data)); in Push()
58 if (!queue_.empty()) { in Pop()
59 data = std::move(queue_.front()); in Pop()
60 queue_.pop(); in Pop()
63 } else if (queue_.empty() && finishFlag_) { in Pop()
91 return static_cast<int>(queue_.size()); in Size()
98 return (0 == queue_.size()); in IsEmpty()
105 while (!queue_.empty()) { in Clear()
106 queue_ in Clear()
[all...]
/foundation/resourceschedule/ffrt/src/queue/
H A Dqueue_handler.cpp50 queue_ = CreateQueue(type, attr); in QueueHandler()
51 FFRT_COND_DO_ERR((queue_ == nullptr), return, "[queueId=%u] constructed failed", GetQueueId()); in QueueHandler()
66 FFRT_COND_DO_ERR((queue_ == nullptr), return, "cannot destruct, [queueId=%u] constructed failed", GetQueueId()); in ~QueueHandler()
69 queue_->Stop(); in ~QueueHandler()
70 while (QueueMonitor::GetInstance().QueryQueueStatus(GetQueueId()) || queue_->GetActiveStatus()) { in ~QueueHandler()
92 FFRT_COND_DO_ERR((queue_ == nullptr), return false, "[queueId=%u] constructed failed", GetQueueId()); in SetLoop()
93 if (queue_->GetQueueType() == ffrt_queue_eventhandler_interactive) { in SetLoop()
96 FFRT_COND_DO_ERR((queue_->GetQueueType() != ffrt_queue_concurrent), in SetLoop()
98 return reinterpret_cast<ConcurrentQueue*>(queue_.get())->SetLoop(loop); in SetLoop()
103 FFRT_COND_DO_ERR((queue_ in ClearLoop()
[all...]
H A Dqueue_handler.h54 return !isUsed_.load() && (queue_->GetQueueType() == ffrt_queue_concurrent in IsValidForLoop()
55 || queue_->GetQueueType() == ffrt_queue_eventhandler_interactive); in IsValidForLoop()
65 FFRT_COND_DO_ERR((queue_ == nullptr), return 0, "queue construct failed"); in GetQueueId()
66 return queue_->GetQueueId(); in GetQueueId()
71 FFRT_COND_DO_ERR((queue_ == nullptr), return false, "[queueId=%u] constructed failed", GetQueueId()); in HasTask()
72 return queue_->HasTask(name); in HasTask()
84 return queue_; in GetQueue()
97 std::unique_ptr<BaseQueue> queue_ = nullptr; member in ffrt::QueueHandler
/foundation/ai/intelligent_voice_framework/utils/
H A Dqueue_util.h52 while (queue_.size() >= capacity_) { in Push()
54 notFullCv_.wait(lock, [&]() { return ((queue_.size() < capacity_) || (!IsAvailable())); }); in Push()
58 queue_.push(element); in Push()
67 while (queue_.size() >= capacity_) { in Push()
69 notFullCv_.wait(lock, [&]() { return ((queue_.size() < capacity_) || (!IsAvailable())); }); in Push()
73 queue_.push(std::move(element)); in Push()
82 while (queue_.empty()) { in Pop()
83 notEmptyCv_.wait(lock, [&] { return (!queue_.empty() || !IsAvailable()); }); in Pop()
87 element = std::move(queue_.front()); in Pop()
88 queue_ in Pop()
144 std::queue<T> queue_; global() member in OHOS::IntellVoiceUtils::QueueUtil
[all...]
H A Dmessage_queue.cpp93 while (queue_.empty()) { in ReceiveMsg()
97 msg = queue_.front(); in ReceiveMsg()
98 queue_.pop(); in ReceiveMsg()
107 if (static_cast<uint32_t>(queue_.size()) >= size_ || msg == nullptr) { in SendMsg()
108 INTELL_VOICE_LOG_WARN("send message failed, msg queue full(%{public}d)", static_cast<int>(queue_.size())); in SendMsg()
114 queue_.push(msg); in SendMsg()
130 while (!queue_.empty()) { in Clear()
131 queue_.pop(); in Clear()
/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_; member in OHOS::SoftBus::WifiDirectEventSender
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_; member in OHOS::SoftBus::WifiDirectEventQueue
/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_; member in OHOS::CameraStandard::final
[all...]
/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 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()
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()
/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_; member in OHOS::Storage::DistributedFile::DfsuThreadSafeQueue
/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_; member in OHOS::Ace::SemQueue
/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(t); in Push()
54 queue_.push(std::move(t)); in Push()
59 std::queue<T> queue_; member in OHOS::Rosen::SemQueue
/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(t); in Push()
54 queue_.push(std::move(t)); in Push()
59 std::queue<T> queue_; member in OHOS::Rosen::SemQueue
/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 * MICROSECOND_TO_SECOND)); 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()
/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_ in RemoveTask()
[all...]
/foundation/multimodalinput/input/intention/common/channel/include/
H A Dchannel.h177 std::deque<Event> queue_; member in OHOS::Msdp::DeviceStatus::Channel
199 queue_.clear(); in Disable()
209 if (queue_.size() >= QUEUE_CAPACITY) { in Send()
212 bool needNotify = queue_.empty(); in Send()
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()
238 return !queue_ in Pop()
[all...]
/foundation/resourceschedule/ffrt/src/util/
H A Dts_queue.h34 queue_.push(data); in Push()
42 cond_.wait(lg, [this] { return !queue_.empty(); }); in Pop()
43 auto& res = queue_.front(); in Pop()
44 queue_.pop(); in Pop()
49 std::queue<T> queue_; member in ffrt::TSQueue
/foundation/communication/netstack/utils/http_over_curl/include/
H A Dthread_safe_storage.h38 std::queue<T> queue_; member in OHOS::NetStack::HttpOverCurl::ThreadSafeStorage
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()
/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_; member in OHOS::Rosen::RingQueue
/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()
/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dengine_worker.cpp28 EngineWorker::EngineWorker(Queue<Task> &queue) : queue_(queue) in EngineWorker()
52 if (queue_.IsEmpty()) { in OneAction()
54 CHK_RET(queue_.IsEmpty(), true); in OneAction()
58 int retCode = queue_.PopFront(task); in OneAction()
78 ClearQueue(queue_); in Uninitialize()
/foundation/multimedia/ringtone_library/services/ringtone_scanner/src/
H A Dringtone_scan_executor.cpp29 queue_.push(move(scanner)); in Commit()
45 if (queue_.empty()) { in HandleScanExecution()
49 scanner = std::move(queue_.front()); in HandleScanExecution()
51 queue_.pop(); in HandleScanExecution()
75 queue_.swap(emptyQueue); in Stop()
/foundation/multimedia/media_library/frameworks/services/media_scanner/src/scanner/
H A Dmedia_scan_executor.cpp27 queue_.push(move(scanner)); in Commit()
45 if (queue_.empty()) { in HandleScanExecution()
50 scanner = std::move(queue_.front()); in HandleScanExecution()
51 queue_.pop(); in HandleScanExecution()
75 queue_.swap(emptyQueue); in Stop()

Completed in 215 milliseconds

1234