1// Copyright 2014 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// An implementation of WebThread in terms of base::MessageLoop and 6// base::Thread 7 8#include "mojo/services/html_viewer/webthread_impl.h" 9 10#include "base/bind.h" 11#include "base/bind_helpers.h" 12#include "base/message_loop/message_loop.h" 13#include "base/pending_task.h" 14#include "base/threading/platform_thread.h" 15 16namespace mojo { 17 18WebThreadBase::WebThreadBase() {} 19WebThreadBase::~WebThreadBase() {} 20 21class WebThreadBase::TaskObserverAdapter 22 : public base::MessageLoop::TaskObserver { 23 public: 24 TaskObserverAdapter(WebThread::TaskObserver* observer) 25 : observer_(observer) {} 26 27 virtual void WillProcessTask(const base::PendingTask& pending_task) OVERRIDE { 28 observer_->willProcessTask(); 29 } 30 31 virtual void DidProcessTask(const base::PendingTask& pending_task) OVERRIDE { 32 observer_->didProcessTask(); 33 } 34 35private: 36 WebThread::TaskObserver* observer_; 37}; 38 39void WebThreadBase::addTaskObserver(TaskObserver* observer) { 40 CHECK(isCurrentThread()); 41 std::pair<TaskObserverMap::iterator, bool> result = task_observer_map_.insert( 42 std::make_pair(observer, static_cast<TaskObserverAdapter*>(NULL))); 43 if (result.second) 44 result.first->second = new TaskObserverAdapter(observer); 45 base::MessageLoop::current()->AddTaskObserver(result.first->second); 46} 47 48void WebThreadBase::removeTaskObserver(TaskObserver* observer) { 49 CHECK(isCurrentThread()); 50 TaskObserverMap::iterator iter = task_observer_map_.find(observer); 51 if (iter == task_observer_map_.end()) 52 return; 53 base::MessageLoop::current()->RemoveTaskObserver(iter->second); 54 delete iter->second; 55 task_observer_map_.erase(iter); 56} 57 58WebThreadImpl::WebThreadImpl(const char* name) 59 : thread_(new base::Thread(name)) { 60 thread_->Start(); 61} 62 63void WebThreadImpl::postTask(Task* task) { 64 thread_->message_loop()->PostTask( 65 FROM_HERE, base::Bind(&blink::WebThread::Task::run, base::Owned(task))); 66} 67 68void WebThreadImpl::postDelayedTask(Task* task, long long delay_ms) { 69 thread_->message_loop()->PostDelayedTask( 70 FROM_HERE, 71 base::Bind(&blink::WebThread::Task::run, base::Owned(task)), 72 base::TimeDelta::FromMilliseconds(delay_ms)); 73} 74 75void WebThreadImpl::enterRunLoop() { 76 CHECK(isCurrentThread()); 77 CHECK(!thread_->message_loop()->is_running()); // We don't support nesting. 78 thread_->message_loop()->Run(); 79} 80 81void WebThreadImpl::exitRunLoop() { 82 CHECK(isCurrentThread()); 83 CHECK(thread_->message_loop()->is_running()); 84 thread_->message_loop()->Quit(); 85} 86 87bool WebThreadImpl::isCurrentThread() const { 88 return thread_->thread_id() == base::PlatformThread::CurrentId(); 89} 90 91blink::PlatformThreadId WebThreadImpl::threadId() const { 92 return thread_->thread_id(); 93} 94 95WebThreadImpl::~WebThreadImpl() { 96 thread_->Stop(); 97} 98 99WebThreadImplForMessageLoop::WebThreadImplForMessageLoop( 100 base::MessageLoopProxy* message_loop) 101 : message_loop_(message_loop) {} 102 103void WebThreadImplForMessageLoop::postTask(Task* task) { 104 message_loop_->PostTask( 105 FROM_HERE, base::Bind(&blink::WebThread::Task::run, base::Owned(task))); 106} 107 108void WebThreadImplForMessageLoop::postDelayedTask(Task* task, 109 long long delay_ms) { 110 message_loop_->PostDelayedTask( 111 FROM_HERE, 112 base::Bind(&blink::WebThread::Task::run, base::Owned(task)), 113 base::TimeDelta::FromMilliseconds(delay_ms)); 114} 115 116void WebThreadImplForMessageLoop::enterRunLoop() { 117 CHECK(isCurrentThread()); 118 // We don't support nesting. 119 CHECK(!base::MessageLoop::current()->is_running()); 120 base::MessageLoop::current()->Run(); 121} 122 123void WebThreadImplForMessageLoop::exitRunLoop() { 124 CHECK(isCurrentThread()); 125 CHECK(base::MessageLoop::current()->is_running()); 126 base::MessageLoop::current()->Quit(); 127} 128 129bool WebThreadImplForMessageLoop::isCurrentThread() const { 130 return message_loop_->BelongsToCurrentThread(); 131} 132 133blink::PlatformThreadId WebThreadImplForMessageLoop::threadId() const { 134 return thread_id_; 135} 136 137WebThreadImplForMessageLoop::~WebThreadImplForMessageLoop() {} 138 139} // namespace mojo 140