| 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/worker_scheduler_impl.h" | |
| 11 #include "third_party/WebKit/public/platform/WebTraceLocation.h" | |
| 12 | |
| 13 namespace content { | |
| 14 | |
| 15 WebThreadImplForWorkerScheduler::WebThreadImplForWorkerScheduler( | |
| 16 const char* name) | |
| 17 : thread_(new base::Thread(name)) { | |
| 18 thread_->Start(); | |
| 19 | |
| 20 base::WaitableEvent completion(false, false); | |
| 21 thread_->message_loop()->PostTask( | |
| 22 FROM_HERE, base::Bind(&WebThreadImplForWorkerScheduler::InitOnThread, | |
| 23 base::Unretained(this), &completion)); | |
| 24 completion.Wait(); | |
| 25 } | |
| 26 | |
| 27 WebThreadImplForWorkerScheduler::~WebThreadImplForWorkerScheduler() { | |
| 28 base::WaitableEvent completion(false, false); | |
| 29 thread_->message_loop()->PostTask( | |
| 30 FROM_HERE, base::Bind(&WebThreadImplForWorkerScheduler::ShutDownOnThread, | |
| 31 base::Unretained(this), &completion)); | |
| 32 completion.Wait(); | |
| 33 | |
| 34 thread_->Stop(); | |
| 35 } | |
| 36 | |
| 37 void WebThreadImplForWorkerScheduler::InitOnThread( | |
| 38 base::WaitableEvent* completion) { | |
| 39 worker_scheduler_ = WorkerScheduler::Create(thread_->message_loop()); | |
| 40 worker_scheduler_->Init(); | |
| 41 task_runner_ = worker_scheduler_->DefaultTaskRunner(); | |
| 42 idle_task_runner_ = worker_scheduler_->IdleTaskRunner(); | |
| 43 completion->Signal(); | |
| 44 } | |
| 45 | |
| 46 void WebThreadImplForWorkerScheduler::ShutDownOnThread( | |
| 47 base::WaitableEvent* completion) { | |
| 48 task_runner_ = nullptr; | |
| 49 idle_task_runner_ = nullptr; | |
| 50 worker_scheduler_.reset(nullptr); | |
| 51 completion->Signal(); | |
| 52 } | |
| 53 | |
| 54 blink::PlatformThreadId WebThreadImplForWorkerScheduler::threadId() const { | |
| 55 return thread_->thread_id(); | |
| 56 } | |
| 57 | |
| 58 base::MessageLoop* WebThreadImplForWorkerScheduler::MessageLoop() const { | |
| 59 // As per WebThreadImpl::MessageLoop() | |
| 60 return nullptr; | |
| 61 } | |
| 62 | |
| 63 base::SingleThreadTaskRunner* WebThreadImplForWorkerScheduler::TaskRunner() | |
| 64 const { | |
| 65 return task_runner_.get(); | |
| 66 } | |
| 67 | |
| 68 SingleThreadIdleTaskRunner* WebThreadImplForWorkerScheduler::IdleTaskRunner() | |
| 69 const { | |
| 70 return idle_task_runner_.get(); | |
| 71 } | |
| 72 | |
| 73 void WebThreadImplForWorkerScheduler::AddTaskObserverInternal( | |
| 74 base::MessageLoop::TaskObserver* observer) { | |
| 75 worker_scheduler_->AddTaskObserver(observer); | |
| 76 } | |
| 77 | |
| 78 void WebThreadImplForWorkerScheduler::RemoveTaskObserverInternal( | |
| 79 base::MessageLoop::TaskObserver* observer) { | |
| 80 worker_scheduler_->RemoveTaskObserver(observer); | |
| 81 } | |
| 82 | |
| 83 } // namespace content | |
| OLD | NEW |