Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(10)

Side by Side Diff: components/scheduler/child/webthread_impl_for_worker_scheduler.h

Issue 2118903002: scheduler: Move the Blink scheduler into Blink (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebased Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
(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 #ifndef COMPONENTS_SCHEDULER_CHILD_WEBTHREAD_IMPL_FOR_WORKER_SCHEDULER_H_
6 #define COMPONENTS_SCHEDULER_CHILD_WEBTHREAD_IMPL_FOR_WORKER_SCHEDULER_H_
7
8 #include "base/threading/thread.h"
9 #include "components/scheduler/base/task_queue_manager.h"
10 #include "components/scheduler/child/webthread_base.h"
11
12 namespace base {
13 class WaitableEvent;
14 };
15
16 namespace blink {
17 class WebScheduler;
18 };
19
20 namespace scheduler {
21 class SchedulerTqmDelegate;
22 class SingleThreadIdleTaskRunner;
23 class TaskQueue;
24 class WebSchedulerImpl;
25 class WebTaskRunnerImpl;
26 class WorkerScheduler;
27
28 class SCHEDULER_EXPORT WebThreadImplForWorkerScheduler
29 : public WebThreadBase,
30 public base::MessageLoop::DestructionObserver {
31 public:
32 explicit WebThreadImplForWorkerScheduler(const char* name);
33 WebThreadImplForWorkerScheduler(const char* name,
34 base::Thread::Options options);
35 ~WebThreadImplForWorkerScheduler() override;
36
37 void Init();
38
39 // blink::WebThread implementation.
40 blink::WebScheduler* scheduler() const override;
41 blink::PlatformThreadId threadId() const override;
42 blink::WebTaskRunner* getWebTaskRunner() override;
43
44 // WebThreadBase implementation.
45 base::SingleThreadTaskRunner* GetTaskRunner() const override;
46 scheduler::SingleThreadIdleTaskRunner* GetIdleTaskRunner() const override;
47
48 // base::MessageLoop::DestructionObserver implementation.
49 void WillDestroyCurrentMessageLoop() override;
50
51 protected:
52 base::Thread* thread() const { return thread_.get(); }
53
54 private:
55 virtual std::unique_ptr<scheduler::WorkerScheduler> CreateWorkerScheduler();
56
57 void AddTaskObserverInternal(
58 base::MessageLoop::TaskObserver* observer) override;
59 void RemoveTaskObserverInternal(
60 base::MessageLoop::TaskObserver* observer) override;
61
62 void InitOnThread(base::WaitableEvent* completion);
63 void RestoreTaskRunnerOnThread(base::WaitableEvent* completion);
64
65 std::unique_ptr<base::Thread> thread_;
66 std::unique_ptr<scheduler::WorkerScheduler> worker_scheduler_;
67 std::unique_ptr<scheduler::WebSchedulerImpl> web_scheduler_;
68 scoped_refptr<base::SingleThreadTaskRunner> thread_task_runner_;
69 scoped_refptr<TaskQueue> task_runner_;
70 scoped_refptr<scheduler::SingleThreadIdleTaskRunner> idle_task_runner_;
71 scoped_refptr<SchedulerTqmDelegate> task_runner_delegate_;
72 std::unique_ptr<WebTaskRunnerImpl> web_task_runner_;
73 };
74
75 } // namespace scheduler
76
77 #endif // COMPONENTS_SCHEDULER_CHILD_WEBTHREAD_IMPL_FOR_WORKER_SCHEDULER_H_
OLDNEW
« no previous file with comments | « components/scheduler/child/webthread_base.cc ('k') | components/scheduler/child/webthread_impl_for_worker_scheduler.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698