OLD | NEW |
| (Empty) |
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 CONTENT_CHILD_WEBTHREAD_IMPL_H_ | |
6 #define CONTENT_CHILD_WEBTHREAD_IMPL_H_ | |
7 | |
8 #include <map> | |
9 | |
10 #include "base/memory/scoped_ptr.h" | |
11 #include "base/threading/thread.h" | |
12 #include "content/common/content_export.h" | |
13 #include "third_party/WebKit/public/platform/WebThread.h" | |
14 | |
15 namespace blink { | |
16 class WebTraceLocation; | |
17 } | |
18 | |
19 namespace content { | |
20 | |
21 class CONTENT_EXPORT WebThreadBase : public blink::WebThread { | |
22 public: | |
23 virtual ~WebThreadBase(); | |
24 | |
25 // blink::WebThread implementation. | |
26 virtual bool isCurrentThread() const; | |
27 virtual blink::PlatformThreadId threadId() const = 0; | |
28 | |
29 virtual void postTask(const blink::WebTraceLocation& location, Task* task); | |
30 virtual void postDelayedTask(const blink::WebTraceLocation& location, | |
31 Task* task, | |
32 long long delay_ms); | |
33 | |
34 virtual void enterRunLoop(); | |
35 virtual void exitRunLoop(); | |
36 | |
37 virtual void addTaskObserver(TaskObserver* observer); | |
38 virtual void removeTaskObserver(TaskObserver* observer); | |
39 | |
40 // Returns the base::Bind-compatible task runner for posting tasks to this | |
41 // thread. Can be called from any thread. | |
42 virtual base::SingleThreadTaskRunner* TaskRunner() const = 0; | |
43 | |
44 protected: | |
45 class TaskObserverAdapter; | |
46 | |
47 WebThreadBase(); | |
48 | |
49 // Returns the underlying MessageLoop for this thread. Only used for entering | |
50 // and exiting a nested run loop. Only called on the thread that the | |
51 // WebThread belongs to. | |
52 virtual base::MessageLoop* MessageLoop() const = 0; | |
53 | |
54 virtual void AddTaskObserverInternal( | |
55 base::MessageLoop::TaskObserver* observer); | |
56 virtual void RemoveTaskObserverInternal( | |
57 base::MessageLoop::TaskObserver* observer); | |
58 | |
59 static void RunWebThreadTask(scoped_ptr<blink::WebThread::Task> task); | |
60 | |
61 private: | |
62 typedef std::map<TaskObserver*, TaskObserverAdapter*> TaskObserverMap; | |
63 TaskObserverMap task_observer_map_; | |
64 }; | |
65 | |
66 class CONTENT_EXPORT WebThreadImpl : public WebThreadBase { | |
67 public: | |
68 explicit WebThreadImpl(const char* name); | |
69 virtual ~WebThreadImpl(); | |
70 | |
71 // blink::WebThread implementation. | |
72 blink::PlatformThreadId threadId() const override; | |
73 | |
74 // WebThreadBase implementation. | |
75 base::SingleThreadTaskRunner* TaskRunner() const override; | |
76 | |
77 private: | |
78 base::MessageLoop* MessageLoop() const override; | |
79 | |
80 scoped_ptr<base::Thread> thread_; | |
81 }; | |
82 | |
83 } // namespace content | |
84 | |
85 #endif // CONTENT_CHILD_WEBTHREAD_IMPL_H_ | |
OLD | NEW |