webthread_impl.h revision 1320f92c476a1ad9d19dba2a48c72b75566198e9 
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#ifndef MOJO_SERVICES_HTML_VIEWER_WEBTHREAD_IMPL_H_
6#define MOJO_SERVICES_HTML_VIEWER_WEBTHREAD_IMPL_H_
7
8#include <map>
9
10#include "base/memory/scoped_ptr.h"
11#include "base/threading/thread.h"
12#include "third_party/WebKit/public/platform/WebThread.h"
13
14namespace mojo {
15
16class WebThreadBase : public blink::WebThread {
17 public:
18  virtual ~WebThreadBase();
19
20  virtual void addTaskObserver(TaskObserver* observer);
21  virtual void removeTaskObserver(TaskObserver* observer);
22
23  virtual bool isCurrentThread() const = 0;
24  virtual blink::PlatformThreadId threadId() const = 0;
25
26 protected:
27  WebThreadBase();
28
29 private:
30  class TaskObserverAdapter;
31
32  typedef std::map<TaskObserver*, TaskObserverAdapter*> TaskObserverMap;
33  TaskObserverMap task_observer_map_;
34};
35
36class WebThreadImpl : public WebThreadBase {
37 public:
38  explicit WebThreadImpl(const char* name);
39  virtual ~WebThreadImpl();
40
41  virtual void postTask(Task* task);
42  virtual void postDelayedTask(Task* task, long long delay_ms);
43
44  virtual void enterRunLoop();
45  virtual void exitRunLoop();
46
47  base::MessageLoop* message_loop() const { return thread_->message_loop(); }
48
49  virtual bool isCurrentThread() const;
50  virtual blink::PlatformThreadId threadId() const;
51
52 private:
53  scoped_ptr<base::Thread> thread_;
54};
55
56class WebThreadImplForMessageLoop : public WebThreadBase {
57 public:
58  explicit WebThreadImplForMessageLoop(
59      base::MessageLoopProxy* message_loop);
60  virtual ~WebThreadImplForMessageLoop();
61
62  virtual void postTask(Task* task);
63  virtual void postDelayedTask(Task* task, long long delay_ms);
64
65  virtual void enterRunLoop();
66  virtual void exitRunLoop();
67
68 private:
69  virtual bool isCurrentThread() const;
70  virtual blink::PlatformThreadId threadId() const;
71
72  scoped_refptr<base::MessageLoopProxy> message_loop_;
73  blink::PlatformThreadId thread_id_;
74};
75
76}  // namespace mojo
77
78#endif  // MOJO_SERVICES_HTML_VIEWER_WEBTHREAD_IMPL_H_
79