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

Side by Side Diff: base/task_scheduler/post_task.cc

Issue 2831883003: Do not inherit TaskPriority in TaskTraits. (Closed)
Patch Set: self-review Created 3 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 2016 The Chromium Authors. All rights reserved. 1 // Copyright 2016 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 "base/task_scheduler/post_task.h" 5 #include "base/task_scheduler/post_task.h"
6 6
7 #include <utility> 7 #include <utility>
8 8
9 #include "base/logging.h" 9 #include "base/logging.h"
10 #include "base/task_scheduler/scoped_set_task_priority_for_current_thread.h"
10 #include "base/task_scheduler/task_scheduler.h" 11 #include "base/task_scheduler/task_scheduler.h"
11 #include "base/threading/post_task_and_reply_impl.h" 12 #include "base/threading/post_task_and_reply_impl.h"
12 13
13 namespace base { 14 namespace base {
14 15
15 namespace { 16 namespace {
16 17
18 TaskTraits SetExplicitPriorityInTaskTraits(const TaskTraits& traits) {
19 TaskTraits traits_with_explicit_priority(traits);
fdoray 2017/04/21 15:22:51 I'm aware that this is not tested. Instead of writ
20 if (traits.priority() == TaskPriority::INHERITED) {
21 traits_with_explicit_priority.WithPriority(
22 internal::GetTaskPriorityForCurrentThread());
23 }
24 return traits_with_explicit_priority;
25 }
26
17 class PostTaskAndReplyTaskRunner : public internal::PostTaskAndReplyImpl { 27 class PostTaskAndReplyTaskRunner : public internal::PostTaskAndReplyImpl {
18 public: 28 public:
19 explicit PostTaskAndReplyTaskRunner(const TaskTraits& traits) 29 explicit PostTaskAndReplyTaskRunner(const TaskTraits& traits)
20 : traits_(traits) {} 30 : traits_(traits) {}
21 31
22 private: 32 private:
23 bool PostTask(const tracked_objects::Location& from_here, 33 bool PostTask(const tracked_objects::Location& from_here,
24 OnceClosure task) override { 34 OnceClosure task) override {
25 PostTaskWithTraits(from_here, traits_, std::move(task)); 35 PostTaskWithTraits(from_here, traits_, std::move(task));
26 return true; 36 return true;
(...skipping 28 matching lines...) Expand all
55 PostDelayedTaskWithTraits(from_here, traits, std::move(task), TimeDelta()); 65 PostDelayedTaskWithTraits(from_here, traits, std::move(task), TimeDelta());
56 } 66 }
57 67
58 void PostDelayedTaskWithTraits(const tracked_objects::Location& from_here, 68 void PostDelayedTaskWithTraits(const tracked_objects::Location& from_here,
59 const TaskTraits& traits, 69 const TaskTraits& traits,
60 OnceClosure task, 70 OnceClosure task,
61 TimeDelta delay) { 71 TimeDelta delay) {
62 DCHECK(TaskScheduler::GetInstance()) 72 DCHECK(TaskScheduler::GetInstance())
63 << "Ref. Prerequisite section of post_task.h"; 73 << "Ref. Prerequisite section of post_task.h";
64 TaskScheduler::GetInstance()->PostDelayedTaskWithTraits( 74 TaskScheduler::GetInstance()->PostDelayedTaskWithTraits(
65 from_here, traits, std::move(task), std::move(delay)); 75 from_here, SetExplicitPriorityInTaskTraits(traits), std::move(task),
76 std::move(delay));
66 } 77 }
67 78
68 void PostTaskWithTraitsAndReply(const tracked_objects::Location& from_here, 79 void PostTaskWithTraitsAndReply(const tracked_objects::Location& from_here,
69 const TaskTraits& traits, 80 const TaskTraits& traits,
70 OnceClosure task, 81 OnceClosure task,
71 OnceClosure reply) { 82 OnceClosure reply) {
72 PostTaskAndReplyTaskRunner(traits).PostTaskAndReply( 83 PostTaskAndReplyTaskRunner(traits).PostTaskAndReply(
73 from_here, std::move(task), std::move(reply)); 84 from_here, std::move(task), std::move(reply));
74 } 85 }
75 86
76 scoped_refptr<TaskRunner> CreateTaskRunnerWithTraits(const TaskTraits& traits) { 87 scoped_refptr<TaskRunner> CreateTaskRunnerWithTraits(const TaskTraits& traits) {
77 DCHECK(TaskScheduler::GetInstance()) 88 DCHECK(TaskScheduler::GetInstance())
78 << "Ref. Prerequisite section of post_task.h"; 89 << "Ref. Prerequisite section of post_task.h";
79 return TaskScheduler::GetInstance()->CreateTaskRunnerWithTraits(traits); 90 return TaskScheduler::GetInstance()->CreateTaskRunnerWithTraits(
91 SetExplicitPriorityInTaskTraits(traits));
80 } 92 }
81 93
82 scoped_refptr<SequencedTaskRunner> CreateSequencedTaskRunnerWithTraits( 94 scoped_refptr<SequencedTaskRunner> CreateSequencedTaskRunnerWithTraits(
83 const TaskTraits& traits) { 95 const TaskTraits& traits) {
84 DCHECK(TaskScheduler::GetInstance()) 96 DCHECK(TaskScheduler::GetInstance())
85 << "Ref. Prerequisite section of post_task.h"; 97 << "Ref. Prerequisite section of post_task.h";
86 return TaskScheduler::GetInstance()->CreateSequencedTaskRunnerWithTraits( 98 return TaskScheduler::GetInstance()->CreateSequencedTaskRunnerWithTraits(
87 traits); 99 SetExplicitPriorityInTaskTraits(traits));
88 } 100 }
89 101
90 scoped_refptr<SingleThreadTaskRunner> CreateSingleThreadTaskRunnerWithTraits( 102 scoped_refptr<SingleThreadTaskRunner> CreateSingleThreadTaskRunnerWithTraits(
91 const TaskTraits& traits) { 103 const TaskTraits& traits) {
92 DCHECK(TaskScheduler::GetInstance()) 104 DCHECK(TaskScheduler::GetInstance())
93 << "Ref. Prerequisite section of post_task.h"; 105 << "Ref. Prerequisite section of post_task.h";
94 return TaskScheduler::GetInstance()->CreateSingleThreadTaskRunnerWithTraits( 106 return TaskScheduler::GetInstance()->CreateSingleThreadTaskRunnerWithTraits(
95 traits); 107 SetExplicitPriorityInTaskTraits(traits));
96 } 108 }
97 109
98 #if defined(OS_WIN) 110 #if defined(OS_WIN)
99 scoped_refptr<SingleThreadTaskRunner> CreateCOMSTATaskRunnerWithTraits( 111 scoped_refptr<SingleThreadTaskRunner> CreateCOMSTATaskRunnerWithTraits(
100 const TaskTraits& traits) { 112 const TaskTraits& traits) {
101 DCHECK(TaskScheduler::GetInstance()) 113 DCHECK(TaskScheduler::GetInstance())
102 << "Ref. Prerequisite section of post_task.h"; 114 << "Ref. Prerequisite section of post_task.h";
103 return TaskScheduler::GetInstance()->CreateCOMSTATaskRunnerWithTraits(traits); 115 return TaskScheduler::GetInstance()->CreateCOMSTATaskRunnerWithTraits(
116 SetExplicitPriorityInTaskTraits(traits));
104 } 117 }
105 #endif // defined(OS_WIN) 118 #endif // defined(OS_WIN)
106 119
107 } // namespace base 120 } // namespace base
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698