Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(88)

Unified Diff: components/scheduler/base/work_queue.cc

Issue 1886453003: Make PendingTask move-only and pass it by value on retaining params (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: components/scheduler/base/work_queue.cc
diff --git a/components/scheduler/base/work_queue.cc b/components/scheduler/base/work_queue.cc
index 313baa9af36fc570d1abcd97e70041f30e6e8334..5bb55ec9a9aee9fafc8c610157e41e6e7c6f2a2c 100644
--- a/components/scheduler/base/work_queue.cc
+++ b/components/scheduler/base/work_queue.cc
@@ -16,11 +16,17 @@ WorkQueue::WorkQueue(TaskQueueImpl* task_queue, const char* name)
name_(name) {}
void WorkQueue::AsValueInto(base::trace_event::TracedValue* state) const {
- std::queue<TaskQueueImpl::Task> queue_copy(work_queue_);
- while (!queue_copy.empty()) {
- TaskQueueImpl::TaskAsValueInto(queue_copy.front(), state);
- queue_copy.pop();
+ // Remove const to search |work_queue_| in the destructive manner. Restore the
+ // content from |visited| later.
+ std::queue<TaskQueueImpl::Task>& mutable_queue =
Sami 2016/04/13 11:33:00 Ditto.
tzik 2016/04/13 14:35:37 Done.
+ const_cast<std::queue<TaskQueueImpl::Task>&>(work_queue_);
+ std::queue<TaskQueueImpl::Task> visited;
+ while (!mutable_queue.empty()) {
+ TaskQueueImpl::TaskAsValueInto(mutable_queue.front(), state);
+ visited.push(std::move(mutable_queue.front()));
+ mutable_queue.pop();
}
+ mutable_queue = std::move(visited);
}
WorkQueue::~WorkQueue() {
@@ -41,17 +47,17 @@ bool WorkQueue::GetFrontTaskEnqueueOrder(EnqueueOrder* enqueue_order) const {
return true;
}
-void WorkQueue::Push(const TaskQueueImpl::Task& task) {
+void WorkQueue::Push(TaskQueueImpl::Task task) {
bool was_empty = work_queue_.empty();
- work_queue_.push(task);
+ work_queue_.push(std::move(task));
if (was_empty && work_queue_sets_)
work_queue_sets_->OnPushQueue(this);
}
-void WorkQueue::PushAndSetEnqueueOrder(const TaskQueueImpl::Task& task,
+void WorkQueue::PushAndSetEnqueueOrder(TaskQueueImpl::Task task,
EnqueueOrder enqueue_order) {
bool was_empty = work_queue_.empty();
- work_queue_.push(task);
+ work_queue_.push(std::move(task));
work_queue_.back().set_enqueue_order(enqueue_order);
if (was_empty && work_queue_sets_)
« components/scheduler/base/task_queue_impl.cc ('K') | « components/scheduler/base/work_queue.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698