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

Side by Side 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: mac test fix Created 4 years, 5 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 unified diff | Download patch
« no previous file with comments | « components/scheduler/base/work_queue.h ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "components/scheduler/base/work_queue.h" 5 #include "components/scheduler/base/work_queue.h"
6 6
7 #include "components/scheduler/base/work_queue_sets.h" 7 #include "components/scheduler/base/work_queue_sets.h"
8 8
9 namespace scheduler { 9 namespace scheduler {
10 namespace internal { 10 namespace internal {
11 11
12 WorkQueue::WorkQueue(TaskQueueImpl* task_queue, const char* name) 12 WorkQueue::WorkQueue(TaskQueueImpl* task_queue, const char* name)
13 : work_queue_sets_(nullptr), 13 : work_queue_sets_(nullptr),
14 task_queue_(task_queue), 14 task_queue_(task_queue),
15 work_queue_set_index_(0), 15 work_queue_set_index_(0),
16 name_(name) {} 16 name_(name) {}
17 17
18 void WorkQueue::AsValueInto(base::trace_event::TracedValue* state) const { 18 void WorkQueue::AsValueInto(base::trace_event::TracedValue* state) const {
19 std::queue<TaskQueueImpl::Task> queue_copy(work_queue_); 19 // Remove const to search |work_queue_| in the destructive manner. Restore the
20 while (!queue_copy.empty()) { 20 // content from |visited| later.
21 TaskQueueImpl::TaskAsValueInto(queue_copy.front(), state); 21 std::queue<TaskQueueImpl::Task>* mutable_queue =
22 queue_copy.pop(); 22 const_cast<std::queue<TaskQueueImpl::Task>*>(&work_queue_);
23 std::queue<TaskQueueImpl::Task> visited;
24 while (!mutable_queue->empty()) {
25 TaskQueueImpl::TaskAsValueInto(mutable_queue->front(), state);
26 visited.push(std::move(mutable_queue->front()));
27 mutable_queue->pop();
23 } 28 }
29 *mutable_queue = std::move(visited);
24 } 30 }
25 31
26 WorkQueue::~WorkQueue() { 32 WorkQueue::~WorkQueue() {
27 DCHECK(!work_queue_sets_) << task_queue_ ->GetName() << " : " 33 DCHECK(!work_queue_sets_) << task_queue_ ->GetName() << " : "
28 << work_queue_sets_->name() << " : " << name_; 34 << work_queue_sets_->name() << " : " << name_;
29 } 35 }
30 36
31 const TaskQueueImpl::Task* WorkQueue::GetFrontTask() const { 37 const TaskQueueImpl::Task* WorkQueue::GetFrontTask() const {
32 if (work_queue_.empty()) 38 if (work_queue_.empty())
33 return nullptr; 39 return nullptr;
34 return &work_queue_.front(); 40 return &work_queue_.front();
35 } 41 }
36 42
37 bool WorkQueue::GetFrontTaskEnqueueOrder(EnqueueOrder* enqueue_order) const { 43 bool WorkQueue::GetFrontTaskEnqueueOrder(EnqueueOrder* enqueue_order) const {
38 if (work_queue_.empty()) 44 if (work_queue_.empty())
39 return false; 45 return false;
40 *enqueue_order = work_queue_.front().enqueue_order(); 46 *enqueue_order = work_queue_.front().enqueue_order();
41 return true; 47 return true;
42 } 48 }
43 49
44 void WorkQueue::Push(const TaskQueueImpl::Task& task) { 50 void WorkQueue::Push(TaskQueueImpl::Task task) {
45 bool was_empty = work_queue_.empty(); 51 bool was_empty = work_queue_.empty();
46 work_queue_.push(task); 52 work_queue_.push(std::move(task));
47 if (was_empty && work_queue_sets_) 53 if (was_empty && work_queue_sets_)
48 work_queue_sets_->OnPushQueue(this); 54 work_queue_sets_->OnPushQueue(this);
49 } 55 }
50 56
51 void WorkQueue::PushAndSetEnqueueOrder(const TaskQueueImpl::Task& task, 57 void WorkQueue::PushAndSetEnqueueOrder(TaskQueueImpl::Task task,
52 EnqueueOrder enqueue_order) { 58 EnqueueOrder enqueue_order) {
53 bool was_empty = work_queue_.empty(); 59 bool was_empty = work_queue_.empty();
54 work_queue_.push(task); 60 work_queue_.push(std::move(task));
55 work_queue_.back().set_enqueue_order(enqueue_order); 61 work_queue_.back().set_enqueue_order(enqueue_order);
56 62
57 if (was_empty && work_queue_sets_) 63 if (was_empty && work_queue_sets_)
58 work_queue_sets_->OnPushQueue(this); 64 work_queue_sets_->OnPushQueue(this);
59 } 65 }
60 66
61 void WorkQueue::PopTaskForTest() { 67 void WorkQueue::PopTaskForTest() {
62 work_queue_.pop(); 68 work_queue_.pop();
63 } 69 }
64 70
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after
96 bool have_task = GetFrontTaskEnqueueOrder(&enqueue_order); 102 bool have_task = GetFrontTaskEnqueueOrder(&enqueue_order);
97 bool have_other_task = 103 bool have_other_task =
98 other_queue->GetFrontTaskEnqueueOrder(&other_enqueue_order); 104 other_queue->GetFrontTaskEnqueueOrder(&other_enqueue_order);
99 DCHECK(have_task); 105 DCHECK(have_task);
100 DCHECK(have_other_task); 106 DCHECK(have_other_task);
101 return enqueue_order < other_enqueue_order; 107 return enqueue_order < other_enqueue_order;
102 } 108 }
103 109
104 } // namespace internal 110 } // namespace internal
105 } // namespace scheduler 111 } // namespace scheduler
OLDNEW
« no previous file with comments | « components/scheduler/base/work_queue.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698