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.
5 #ifndef MOJO_EXAMPLES_HTML_VIEWER_WEBTHREAD_IMPL_H_
6 #define MOJO_EXAMPLES_HTML_VIEWER_WEBTHREAD_IMPL_H_
10 #include "base/memory/scoped_ptr.h"
11 #include "base/threading/thread.h"
12 #include "third_party/WebKit/public/platform/WebThread.h"
17 class WebThreadBase : public blink::WebThread {
19 virtual ~WebThreadBase();
21 virtual void addTaskObserver(TaskObserver* observer);
22 virtual void removeTaskObserver(TaskObserver* observer);
24 virtual bool isCurrentThread() const = 0;
30 class TaskObserverAdapter;
32 typedef std::map<TaskObserver*, TaskObserverAdapter*> TaskObserverMap;
33 TaskObserverMap task_observer_map_;
36 class WebThreadImpl : public WebThreadBase {
38 explicit WebThreadImpl(const char* name);
39 virtual ~WebThreadImpl();
41 virtual void postTask(Task* task);
42 virtual void postDelayedTask(Task* task, long long delay_ms);
44 virtual void enterRunLoop();
45 virtual void exitRunLoop();
47 base::MessageLoop* message_loop() const { return thread_->message_loop(); }
49 virtual bool isCurrentThread() const;
52 scoped_ptr<base::Thread> thread_;
55 class WebThreadImplForMessageLoop : public WebThreadBase {
57 explicit WebThreadImplForMessageLoop(
58 base::MessageLoopProxy* message_loop);
59 virtual ~WebThreadImplForMessageLoop();
61 virtual void postTask(Task* task);
62 virtual void postDelayedTask(Task* task, long long delay_ms);
64 virtual void enterRunLoop();
65 virtual void exitRunLoop();
68 virtual bool isCurrentThread() const;
69 scoped_refptr<base::MessageLoopProxy> message_loop_;
72 } // namespace examples
75 #endif // MOJO_EXAMPLES_HTML_VIEWER_WEBTHREAD_IMPL_H_