| /foundation/resourceschedule/frame_aware_sched/interfaces/innerkits/frameintf/ |
| H A D | frame_msg_intf.cpp | 35 if (taskQueue_ != nullptr) { in ~FrameMsgIntf()
36 delete taskQueue_; in ~FrameMsgIntf()
37 taskQueue_ = nullptr; in ~FrameMsgIntf()
48 taskQueue_->submit([] { in Init()
56 if (taskQueue_ == nullptr) { in GetThreadQueue()
57 taskQueue_ = new(ffrt::queue)("frame_aware_sched_msg_queue", in GetThreadQueue()
59 if (taskQueue_ == nullptr) { in GetThreadQueue()
71 if (taskQueue_ == nullptr) { in ReportWindowFocus()
75 taskQueue_->submit([pid, uid, isFocus] { in ReportWindowFocus()
84 if (taskQueue_ in ReportRenderThread()
[all...] |
| H A D | frame_msg_intf.h | 45 ffrt::queue* taskQueue_ = nullptr; member in OHOS::RME::FrameMsgIntf
|
| /foundation/ability/ability_runtime/services/common/src/ |
| H A D | queue_task_handler_wrap.cpp | 23 : taskQueue_(queueName.c_str(), ffrt::queue_attr().qos(Convert2FfrtQos(queueQos)).timeout(QUEUE_TIME_OUT)) in QueueTaskHandlerWrap()
27 : taskQueue_( in QueueTaskHandlerWrap()
37 return std::make_shared<InnerTaskHandle>(taskQueue_.submit_h(std::move(task))); in SubmitTaskInner()
41 return std::make_shared<InnerTaskHandle>(taskQueue_.submit_h(std::move(task), in SubmitTaskInner()
50 return taskQueue_.cancel(taskHandle->GetFfrtHandle()) == 0; in CancelTaskInner()
57 taskQueue_.wait(taskHandle->GetFfrtHandle()); in WaitTaskInner()
|
| H A D | queue_task_handler_wrap.h | 36 ffrt::queue taskQueue_; member in OHOS::AAFwk::QueueTaskHandlerWrap
|
| /foundation/ability/ability_lite/frameworks/ability_lite/src/ |
| H A D | ability_event_handler.cpp | 43 if (taskQueue_.empty()) {
in Run()
46 Task task = std::move(taskQueue_.front());
in Run()
47 taskQueue_.pop();
in Run()
57 if (taskQueue_.size() >= TASK_QUEUE_CAPACITY) {
in PostTask()
61 taskQueue_.push(task);
in PostTask()
|
| /foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/drawing/engine_adapter/skia_adapter/ |
| H A D | skia_task_executor.cpp | 66 while (!taskQueue_.HasSpace()) { in EnqueueTask()
71 taskQueue_.Push(std::move(task)); in EnqueueTask()
72 if (waitingThread_ == DEFAULT_THREAD_COUNT || (waitingThread_ > 0 && taskQueue_.Size() > 1)) { in EnqueueTask()
99 if (!taskQueue_.HasTask()) { in ThreadLoop()
104 while (taskQueue_.HasTask()) { in ThreadLoop()
105 auto task = taskQueue_.Pop(); in ThreadLoop()
|
| H A D | skia_task_executor.h | 138 TaskQueue<Task, QUEUE_SIZE> taskQueue_; member in OHOS::Rosen::TaskPoolExecutor
|
| /foundation/multimedia/media_library/frameworks/services/media_cloud_enhancement/src/utils/ |
| H A D | enhancement_thread_manager.cpp | 59 taskQueue_.push(task);
in OnProducerCallback()
75 return !taskQueue_.empty() || stop;
in DealWithTasks()
77 if (stop && taskQueue_.empty()) {
in DealWithTasks()
81 task = taskQueue_.front();
in DealWithTasks()
82 taskQueue_.pop();
in DealWithTasks()
84 if (taskQueue_.empty()) {
in DealWithTasks()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/task/ |
| H A D | task_executor.cpp | 56 if (taskQueue_.size() > MAX_TASK_QUEUE_LENGTH) { in PushTask()
60 taskQueue_.push(task); in PushTask()
72 return !(this->taskQueue_.empty()); in PopTask()
75 if (!taskQueue_.empty()) { in PopTask()
76 task = taskQueue_.front(); in PopTask()
77 taskQueue_.pop(); in PopTask()
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/util/ |
| H A D | dispatcher.cpp | 23 Dispatcher::Dispatcher(const std::string &name) : name_(name), taskQueue_(128) in Dispatcher()
46 taskQueue_.Push(std::bind(EmptyTask)); in Uninitialize()
57 taskQueue_.Push(std::move(task)); in PostTask()
73 taskQueue_.Pop(task); in Run()
|
| H A D | dispatcher.h | 88 utility::FixedQueue<std::function<void()>> taskQueue_ {};
|
| /foundation/communication/netstack/utils/common_utils/include/ |
| H A D | thread_pool.h | 77 * push it to taskQueue_ and notify a thread to run it
95 return taskQueue_.empty();
in IsQueueEmpty()
102 // if taskQueue_ is empty, means timeout
in GetTask()
103 if (taskQueue_.empty()) {
in GetTask()
107 // if run to this line, means that taskQueue_ is not empty
in GetTask()
108 task = taskQueue_.top();
in GetTask()
109 taskQueue_.pop();
in GetTask()
116 taskQueue_.push(task);
in PushTask()
187 * other thread put a task to the taskQueue_
190 std::priority_queue<Task> taskQueue_;
member in OHOS::NetStack::ThreadPool
[all...] |
| /foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/1.0/src/ |
| H A D | dscreen.cpp | 141 taskQueue_.push(task); in AddTask()
160 [this]() { return !taskQueue_.empty(); }); in TaskThreadLoop()
165 if (taskQueue_.empty()) { in TaskThreadLoop()
168 task = taskQueue_.front(); in TaskThreadLoop()
169 taskQueue_.pop(); in TaskThreadLoop()
177 DHLOGD("run task, task queue size: %{public}zu", taskQueue_.size()); in TaskThreadLoop()
|
| /foundation/ability/ability_lite/interfaces/kits/ability_lite/ |
| H A D | ability_event_handler.h | 87 std::queue<Task> taskQueue_; member in OHOS::AbilityEventHandler
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/task/ |
| H A D | task_executor.h | 40 std::queue<std::shared_ptr<Task>> taskQueue_; member in OHOS::DistributedHardware::TaskExecutor
|
| /foundation/multimedia/media_library/frameworks/services/media_cloud_enhancement/include/utils/ |
| H A D | enhancement_thread_manager.h | 51 std::queue<CloudEnhancementThreadTask> taskQueue_;
member in OHOS::Media::EnhancementThreadManager
|
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
| H A D | medialibrary_notify.cpp | 429 taskQueue_.push(task); in AddTask()
441 if (taskQueue_.empty()) { in GetTask()
444 shared_ptr<MediaLibraryAsyncTask> task = taskQueue_.front(); in GetTask()
445 taskQueue_.pop(); in GetTask()
452 return taskQueue_.empty(); in IsQueueEmpty()
|
| /foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/2.0/src/ |
| H A D | dscreen.cpp | 99 taskQueue_.push(task); in AddTask()
603 [this]() { return !taskQueue_.empty(); }); in TaskThreadLoop()
608 if (taskQueue_.empty()) { in TaskThreadLoop()
611 task = taskQueue_.front(); in TaskThreadLoop()
612 taskQueue_.pop(); in TaskThreadLoop()
618 DHLOGD("run task, task queue size: %{public}zu", taskQueue_.size()); in TaskThreadLoop()
|
| /foundation/ability/form_fwk/services/src/ |
| H A D | form_render_mgr.cpp | 181 taskQueue_.push(task); in AddAcquireProviderFormInfoTask()
189 while (!taskQueue_.empty()) { in ExecAcquireProviderTask()
190 auto task = taskQueue_.front(); in ExecAcquireProviderTask()
192 taskQueue_.pop(); in ExecAcquireProviderTask()
|
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/communicator/ |
| H A D | softbus_adapter_standard.cpp | 46 taskQueue_ = std::make_shared<TaskScheduler>(TASK_CAPACITY_MAX, "data_object");
in SoftBusAdapter()
61 if (taskQueue_ != nullptr) {
in ~SoftBusAdapter()
62 taskQueue_->Clean();
in ~SoftBusAdapter()
63 taskQueue_ = nullptr;
in ~SoftBusAdapter()
510 taskQueue_->Execute(std::move(task));
in DoSend()
|
| /foundation/ability/form_fwk/services/include/ |
| H A D | form_render_mgr.h | 108 std::queue<std::function<void()>> taskQueue_; member in OHOS::AppExecFwk::FormRenderMgr
|
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/include/ |
| H A D | medialibrary_notify.h | 90 COMPILE_HIDDEN std::queue<std::shared_ptr<MediaLibraryAsyncTask>> taskQueue_; member in OHOS::Media::NotifyTaskWorker
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | virtual_cloud_syncer.cpp | 96 return taskQueue_.size(); in GetQueueCount()
|
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/communicator/ |
| H A D | softbus_adapter.h | 112 std::shared_ptr<TaskScheduler> taskQueue_;
member in OHOS::ObjectStore::SoftBusAdapter
|
| /foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/2.0/include/ |
| H A D | dscreen.h | 147 std::queue<std::shared_ptr<Task>> taskQueue_; member in OHOS::DistributedHardware::V2_0::DScreen
|