| OLD | NEW |
|---|
| (Empty) |
| 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 | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "content/child/scheduler/webthread_impl_for_worker_scheduler.h" | |
| 6 | |
| 7 #include "base/bind.h" | |
| 8 #include "base/synchronization/waitable_event.h" | |
| 9 #include "content/child/scheduler/scheduler_message_loop_delegate.h" | |
| 10 #include "content/child/scheduler/web_scheduler_impl.h" | |
| 11 #include "content/child/scheduler/worker_scheduler_impl.h" | |
| 12 #include "third_party/WebKit/public/platform/WebTraceLocation.h" | |
| 13 | |
| 14 namespace content { | |
| 15 | |
| 16 WebThreadImplForWorkerScheduler::WebThreadImplForWorkerScheduler( | |
| 17 const char* name) | |
| 18 : thread_(new base::Thread(name)) { | |
| 19 thread_->Start(); | |
| 20 | |
| 21 base::WaitableEvent completion(false, false); | |
| 22 thread_->message_loop()->PostTask( | |
| 23 FROM_HERE, base::Bind(&WebThreadImplForWorkerScheduler::InitOnThread, | |
| 24 base::Unretained(this), &completion)); | |
| 25 completion.Wait(); | |
| 26 } | |
| 27 | |
| 28 WebThreadImplForWorkerScheduler::~WebThreadImplForWorkerScheduler() { | |
| 29 base::WaitableEvent completion(false, false); | |
| 30 // We need to post the shutdown task on the scheduler's task queue or tasks | |
| 31 // posted on the worker scheduler may not get run when the thread is deleted. | |
| 32 TaskRunner()->PostTask( | |
| 33 FROM_HERE, base::Bind(&WebThreadImplForWorkerScheduler::ShutDownOnThread, | |
| 34 base::Unretained(this), &completion)); | |
| 35 completion.Wait(); | |
| 36 | |
| 37 thread_->Stop(); | |
| 38 } | |
| 39 | |
| 40 void WebThreadImplForWorkerScheduler::InitOnThread( | |
| 41 base::WaitableEvent* completion) { | |
| 42 worker_scheduler_ = WorkerScheduler::Create(thread_->message_loop()); | |
| 43 worker_scheduler_->Init(); | |
| 44 task_runner_ = worker_scheduler_->DefaultTaskRunner(); | |
| 45 idle_task_runner_ = worker_scheduler_->IdleTaskRunner(); | |
| 46 web_scheduler_.reset(new WebSchedulerImpl( | |
| 47 worker_scheduler_.get(), worker_scheduler_->IdleTaskRunner(), | |
| 48 worker_scheduler_->DefaultTaskRunner(), | |
| 49 worker_scheduler_->DefaultTaskRunner())); | |
| 50 completion->Signal(); | |
| 51 } | |
| 52 | |
| 53 void WebThreadImplForWorkerScheduler::ShutDownOnThread( | |
| 54 base::WaitableEvent* completion) { | |
| 55 task_runner_ = nullptr; | |
| 56 idle_task_runner_ = nullptr; | |
| 57 web_scheduler_.reset(); | |
| 58 worker_scheduler_.reset(); | |
| 59 completion->Signal(); | |
| 60 } | |
| 61 | |
| 62 blink::PlatformThreadId WebThreadImplForWorkerScheduler::threadId() const { | |
| 63 return thread_->thread_id(); | |
| 64 } | |
| 65 | |
| 66 blink::WebScheduler* WebThreadImplForWorkerScheduler::scheduler() const { | |
| 67 return web_scheduler_.get(); | |
| 68 } | |
| 69 | |
| 70 base::MessageLoop* WebThreadImplForWorkerScheduler::MessageLoop() const { | |
| 71 // As per WebThreadImpl::MessageLoop() | |
| 72 return nullptr; | |
| 73 } | |
| 74 | |
| 75 base::SingleThreadTaskRunner* WebThreadImplForWorkerScheduler::TaskRunner() | |
| 76 const { | |
| 77 return task_runner_.get(); | |
| 78 } | |
| 79 | |
| 80 SingleThreadIdleTaskRunner* WebThreadImplForWorkerScheduler::IdleTaskRunner() | |
| 81 const { | |
| 82 return idle_task_runner_.get(); | |
| 83 } | |
| 84 | |
| 85 void WebThreadImplForWorkerScheduler::AddTaskObserverInternal( | |
| 86 base::MessageLoop::TaskObserver* observer) { | |
| 87 worker_scheduler_->AddTaskObserver(observer); | |
| 88 } | |
| 89 | |
| 90 void WebThreadImplForWorkerScheduler::RemoveTaskObserverInternal( | |
| 91 base::MessageLoop::TaskObserver* observer) { | |
| 92 worker_scheduler_->RemoveTaskObserver(observer); | |
| 93 } | |
| 94 | |
| 95 } // namespace content | |
| OLD | NEW |
|---|
Chromium Code Reviews
Issue 1058873010:
Move blink scheduler implementation into a component (Closed)
Base URL: https://chromium.googlesource.com/chromium/src.git@master