OLD | NEW |
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/child/webthread_impl_for_worker_scheduler.h" | 5 #include "components/scheduler/child/webthread_impl_for_worker_scheduler.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/location.h" | 8 #include "base/location.h" |
9 #include "base/single_thread_task_runner.h" | 9 #include "base/single_thread_task_runner.h" |
10 #include "base/synchronization/waitable_event.h" | 10 #include "base/synchronization/waitable_event.h" |
11 #include "components/scheduler/child/scheduler_task_runner_delegate_impl.h" | 11 #include "components/scheduler/child/scheduler_task_runner_delegate_impl.h" |
12 #include "components/scheduler/child/task_queue.h" | 12 #include "components/scheduler/child/task_queue.h" |
13 #include "components/scheduler/child/web_scheduler_impl.h" | 13 #include "components/scheduler/child/web_scheduler_impl.h" |
| 14 #include "components/scheduler/child/web_task_runner_impl.h" |
14 #include "components/scheduler/child/worker_scheduler_impl.h" | 15 #include "components/scheduler/child/worker_scheduler_impl.h" |
15 #include "third_party/WebKit/public/platform/WebTraceLocation.h" | 16 #include "third_party/WebKit/public/platform/WebTraceLocation.h" |
16 | 17 |
17 namespace scheduler { | 18 namespace scheduler { |
18 | 19 |
19 WebThreadImplForWorkerScheduler::WebThreadImplForWorkerScheduler( | 20 WebThreadImplForWorkerScheduler::WebThreadImplForWorkerScheduler( |
20 const char* name) | 21 const char* name) |
21 : thread_(new base::Thread(name)) { | 22 : thread_(new base::Thread(name)) { |
22 thread_->Start(); | 23 thread_->Start(); |
23 thread_task_runner_ = thread_->task_runner(); | 24 thread_task_runner_ = thread_->task_runner(); |
(...skipping 22 matching lines...) Expand all Loading... |
46 SchedulerTaskRunnerDelegateImpl::Create(thread_->message_loop()); | 47 SchedulerTaskRunnerDelegateImpl::Create(thread_->message_loop()); |
47 worker_scheduler_ = WorkerScheduler::Create(task_runner_delegate_); | 48 worker_scheduler_ = WorkerScheduler::Create(task_runner_delegate_); |
48 worker_scheduler_->Init(); | 49 worker_scheduler_->Init(); |
49 task_runner_ = worker_scheduler_->DefaultTaskRunner(); | 50 task_runner_ = worker_scheduler_->DefaultTaskRunner(); |
50 idle_task_runner_ = worker_scheduler_->IdleTaskRunner(); | 51 idle_task_runner_ = worker_scheduler_->IdleTaskRunner(); |
51 web_scheduler_.reset(new WebSchedulerImpl( | 52 web_scheduler_.reset(new WebSchedulerImpl( |
52 worker_scheduler_.get(), worker_scheduler_->IdleTaskRunner(), | 53 worker_scheduler_.get(), worker_scheduler_->IdleTaskRunner(), |
53 worker_scheduler_->DefaultTaskRunner(), | 54 worker_scheduler_->DefaultTaskRunner(), |
54 worker_scheduler_->DefaultTaskRunner())); | 55 worker_scheduler_->DefaultTaskRunner())); |
55 base::MessageLoop::current()->AddDestructionObserver(this); | 56 base::MessageLoop::current()->AddDestructionObserver(this); |
| 57 default_web_task_runner_ = |
| 58 make_scoped_ptr(new WebTaskRunnerImpl(task_runner_)); |
56 completion->Signal(); | 59 completion->Signal(); |
57 } | 60 } |
58 | 61 |
59 void WebThreadImplForWorkerScheduler::RestoreTaskRunnerOnThread( | 62 void WebThreadImplForWorkerScheduler::RestoreTaskRunnerOnThread( |
60 base::WaitableEvent* completion) { | 63 base::WaitableEvent* completion) { |
61 task_runner_delegate_->RestoreDefaultTaskRunner(); | 64 task_runner_delegate_->RestoreDefaultTaskRunner(); |
62 completion->Signal(); | 65 completion->Signal(); |
63 } | 66 } |
64 | 67 |
65 void WebThreadImplForWorkerScheduler::WillDestroyCurrentMessageLoop() { | 68 void WebThreadImplForWorkerScheduler::WillDestroyCurrentMessageLoop() { |
(...skipping 14 matching lines...) Expand all Loading... |
80 base::SingleThreadTaskRunner* WebThreadImplForWorkerScheduler::TaskRunner() | 83 base::SingleThreadTaskRunner* WebThreadImplForWorkerScheduler::TaskRunner() |
81 const { | 84 const { |
82 return task_runner_.get(); | 85 return task_runner_.get(); |
83 } | 86 } |
84 | 87 |
85 SingleThreadIdleTaskRunner* WebThreadImplForWorkerScheduler::IdleTaskRunner() | 88 SingleThreadIdleTaskRunner* WebThreadImplForWorkerScheduler::IdleTaskRunner() |
86 const { | 89 const { |
87 return idle_task_runner_.get(); | 90 return idle_task_runner_.get(); |
88 } | 91 } |
89 | 92 |
| 93 blink::WebTaskRunner* WebThreadImplForWorkerScheduler::taskRunner() { |
| 94 return default_web_task_runner_.get(); |
| 95 } |
| 96 |
90 void WebThreadImplForWorkerScheduler::AddTaskObserverInternal( | 97 void WebThreadImplForWorkerScheduler::AddTaskObserverInternal( |
91 base::MessageLoop::TaskObserver* observer) { | 98 base::MessageLoop::TaskObserver* observer) { |
92 worker_scheduler_->AddTaskObserver(observer); | 99 worker_scheduler_->AddTaskObserver(observer); |
93 } | 100 } |
94 | 101 |
95 void WebThreadImplForWorkerScheduler::RemoveTaskObserverInternal( | 102 void WebThreadImplForWorkerScheduler::RemoveTaskObserverInternal( |
96 base::MessageLoop::TaskObserver* observer) { | 103 base::MessageLoop::TaskObserver* observer) { |
97 worker_scheduler_->RemoveTaskObserver(observer); | 104 worker_scheduler_->RemoveTaskObserver(observer); |
98 } | 105 } |
99 | 106 |
100 } // namespace scheduler | 107 } // namespace scheduler |
OLD | NEW |