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

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

Issue 2032603002: Migrate WaitableEvent to enum-based constructor in base/ (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@WEvent_enums
Patch Set: undo incorrect template change Created 4 years, 6 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/task_scheduler_impl.h" 5 #include "base/task_scheduler/task_scheduler_impl.h"
6 6
7 #include <utility> 7 #include <utility>
8 8
9 #include "base/bind.h" 9 #include "base/bind.h"
10 #include "base/bind_helpers.h" 10 #include "base/bind_helpers.h"
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after
61 background_file_io_thread_pool_->JoinForTesting(); 61 background_file_io_thread_pool_->JoinForTesting();
62 normal_thread_pool_->JoinForTesting(); 62 normal_thread_pool_->JoinForTesting();
63 normal_file_io_thread_pool_->JoinForTesting(); 63 normal_file_io_thread_pool_->JoinForTesting();
64 service_thread_->JoinForTesting(); 64 service_thread_->JoinForTesting();
65 #if DCHECK_IS_ON() 65 #if DCHECK_IS_ON()
66 join_for_testing_returned_.Signal(); 66 join_for_testing_returned_.Signal();
67 #endif 67 #endif
68 } 68 }
69 69
70 TaskSchedulerImpl::TaskSchedulerImpl() 70 TaskSchedulerImpl::TaskSchedulerImpl()
71 : delayed_task_manager_(Bind(&TaskSchedulerImpl::OnDelayedRunTimeUpdated, 71 : delayed_task_manager_(
72 Unretained(this))) 72 Bind(&TaskSchedulerImpl::OnDelayedRunTimeUpdated, Unretained(this)))
73 #if DCHECK_IS_ON() 73 #if DCHECK_IS_ON()
74 , 74 ,
75 join_for_testing_returned_(true, false) 75 join_for_testing_returned_(WaitableEvent::ResetPolicy::MANUAL,
76 WaitableEvent::InitialState::NOT_SIGNALED)
76 #endif 77 #endif
77 { 78 {
78 } 79 }
79 80
80 void TaskSchedulerImpl::Initialize() { 81 void TaskSchedulerImpl::Initialize() {
81 using IORestriction = SchedulerThreadPoolImpl::IORestriction; 82 using IORestriction = SchedulerThreadPoolImpl::IORestriction;
82 83
83 const SchedulerThreadPoolImpl::ReEnqueueSequenceCallback 84 const SchedulerThreadPoolImpl::ReEnqueueSequenceCallback
84 re_enqueue_sequence_callback = 85 re_enqueue_sequence_callback =
85 Bind(&TaskSchedulerImpl::ReEnqueueSequenceCallback, Unretained(this)); 86 Bind(&TaskSchedulerImpl::ReEnqueueSequenceCallback, Unretained(this));
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after
147 GetThreadPoolForTraits(traits)->ReEnqueueSequence(std::move(sequence), 148 GetThreadPoolForTraits(traits)->ReEnqueueSequence(std::move(sequence),
148 sort_key); 149 sort_key);
149 } 150 }
150 151
151 void TaskSchedulerImpl::OnDelayedRunTimeUpdated() { 152 void TaskSchedulerImpl::OnDelayedRunTimeUpdated() {
152 service_thread_->WakeUp(); 153 service_thread_->WakeUp();
153 } 154 }
154 155
155 } // namespace internal 156 } // namespace internal
156 } // namespace base 157 } // namespace base
OLDNEW
« no previous file with comments | « base/task_scheduler/scheduler_worker_thread_unittest.cc ('k') | base/task_scheduler/task_scheduler_impl_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698