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

Side by Side Diff: cc/raster/task_graph_runner.h

Issue 1890903002: cc: Simplify Task and its derived classes. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@remove_tile_task_runner
Patch Set: feedback 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 unified diff | Download patch
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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 #ifndef CC_RASTER_TASK_GRAPH_RUNNER_H_ 5 #ifndef CC_RASTER_TASK_GRAPH_RUNNER_H_
6 #define CC_RASTER_TASK_GRAPH_RUNNER_H_ 6 #define CC_RASTER_TASK_GRAPH_RUNNER_H_
7 7
8 #include <stddef.h> 8 #include <stddef.h>
9 #include <stdint.h> 9 #include <stdint.h>
10 10
11 #include <algorithm> 11 #include <algorithm>
12 #include <map> 12 #include <map>
13 #include <memory> 13 #include <memory>
14 #include <vector> 14 #include <vector>
15 15
16 #include "base/logging.h" 16 #include "base/logging.h"
17 #include "base/memory/ref_counted.h" 17 #include "base/memory/ref_counted.h"
18 #include "cc/base/cc_export.h" 18 #include "cc/base/cc_export.h"
19 #include "cc/raster/task.h"
19 20
20 namespace cc { 21 namespace cc {
21 22
22 class TaskGraphRunner;
23
24 // A task which can be run by a TaskGraphRunner. To run a Task, it should be
25 // inserted into a TaskGraph, which can then be scheduled on the
26 // TaskGraphRunner.
27 class CC_EXPORT Task : public base::RefCountedThreadSafe<Task> {
28 public:
29 typedef std::vector<scoped_refptr<Task>> Vector;
30
31 // Subclasses should implement this method. RunOnWorkerThread may be called
32 // on any thread, and subclasses are responsible for locking and thread
33 // safety.
34 virtual void RunOnWorkerThread() = 0;
35
36 void WillRun();
37 void DidRun();
38 bool HasFinishedRunning() const;
39
40 protected:
41 friend class base::RefCountedThreadSafe<Task>;
42
43 Task();
44 virtual ~Task();
45
46 bool will_run_;
47 bool did_run_;
48 };
49
50 // A task dependency graph describes the order in which to execute a set
51 // of tasks. Dependencies are represented as edges. Each node is assigned
52 // a category, a priority and a run count that matches the number of
53 // dependencies. Priority range from 0 (most favorable scheduling) to UINT16_MAX
54 // (least favorable). Categories range from 0 to UINT16_MAX. It is up to the
55 // implementation and its consumer to determine the meaning (if any) of a
56 // category. A TaskGraphRunner implementation may chose to prioritize certain
57 // categories over others, regardless of the individual priorities of tasks.
58 struct CC_EXPORT TaskGraph {
59 struct Node {
60 typedef std::vector<Node> Vector;
61
62 Node(Task* task,
63 uint16_t category,
64 uint16_t priority,
65 uint32_t dependencies)
66 : task(task),
67 category(category),
68 priority(priority),
69 dependencies(dependencies) {}
70
71 Task* task;
72 uint16_t category;
73 uint16_t priority;
74 uint32_t dependencies;
75 };
76
77 struct Edge {
78 typedef std::vector<Edge> Vector;
79
80 Edge(const Task* task, Task* dependent)
81 : task(task), dependent(dependent) {}
82
83 const Task* task;
84 Task* dependent;
85 };
86
87 TaskGraph();
88 TaskGraph(const TaskGraph& other);
89 ~TaskGraph();
90
91 void Swap(TaskGraph* other);
92 void Reset();
93
94 Node::Vector nodes;
95 Edge::Vector edges;
96 };
97
98 // Opaque identifier that defines a namespace of tasks. 23 // Opaque identifier that defines a namespace of tasks.
99 class CC_EXPORT NamespaceToken { 24 class CC_EXPORT NamespaceToken {
100 public: 25 public:
101 NamespaceToken() : id_(0) {} 26 NamespaceToken() : id_(0) {}
102 ~NamespaceToken() {} 27 ~NamespaceToken() {}
103 28
104 bool IsValid() const { return id_ != 0; } 29 bool IsValid() const { return id_ != 0; }
105 30
106 private: 31 private:
107 friend class TaskGraphWorkQueue; 32 friend class TaskGraphWorkQueue;
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after
159 virtual void WaitForTasksToFinishRunning(NamespaceToken token) = 0; 84 virtual void WaitForTasksToFinishRunning(NamespaceToken token) = 0;
160 85
161 // Collect all completed tasks in |completed_tasks|. 86 // Collect all completed tasks in |completed_tasks|.
162 virtual void CollectCompletedTasks(NamespaceToken token, 87 virtual void CollectCompletedTasks(NamespaceToken token,
163 Task::Vector* completed_tasks) = 0; 88 Task::Vector* completed_tasks) = 0;
164 89
165 protected: 90 protected:
166 virtual ~TaskGraphRunner() {} 91 virtual ~TaskGraphRunner() {}
167 }; 92 };
168 93
169 // Helper class for iterating over all dependents of a task.
170 class DependentIterator {
171 public:
172 DependentIterator(TaskGraph* graph, const Task* task)
173 : graph_(graph),
174 task_(task),
175 current_index_(static_cast<size_t>(-1)),
176 current_node_(NULL) {
177 ++(*this);
178 }
179
180 TaskGraph::Node& operator->() const {
181 DCHECK_LT(current_index_, graph_->edges.size());
182 DCHECK_EQ(graph_->edges[current_index_].task, task_);
183 DCHECK(current_node_);
184 return *current_node_;
185 }
186
187 TaskGraph::Node& operator*() const {
188 DCHECK_LT(current_index_, graph_->edges.size());
189 DCHECK_EQ(graph_->edges[current_index_].task, task_);
190 DCHECK(current_node_);
191 return *current_node_;
192 }
193
194 // Note: Performance can be improved by keeping edges sorted.
195 DependentIterator& operator++() {
196 // Find next dependency edge for |task_|.
197 do {
198 ++current_index_;
199 if (current_index_ == graph_->edges.size())
200 return *this;
201 } while (graph_->edges[current_index_].task != task_);
202
203 // Now find the node for the dependent of this edge.
204 TaskGraph::Node::Vector::iterator it = std::find_if(
205 graph_->nodes.begin(), graph_->nodes.end(),
206 [this](const TaskGraph::Node& node) {
207 return node.task == graph_->edges[current_index_].dependent;
208 });
209 DCHECK(it != graph_->nodes.end());
210 current_node_ = &(*it);
211
212 return *this;
213 }
214
215 operator bool() const { return current_index_ < graph_->edges.size(); }
216
217 private:
218 TaskGraph* graph_;
219 const Task* task_;
220 size_t current_index_;
221 TaskGraph::Node* current_node_;
222 };
223
224 } // namespace cc 94 } // namespace cc
225 95
226 #endif // CC_RASTER_TASK_GRAPH_RUNNER_H_ 96 #endif // CC_RASTER_TASK_GRAPH_RUNNER_H_
OLDNEW
« no previous file with comments | « cc/raster/task.cc ('k') | cc/raster/task_graph_runner.cc » ('j') | cc/raster/tile_task_runner.h » ('J')

Powered by Google App Engine
This is Rietveld 408576698