OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #ifndef CONTENT_CHILD_SCHEDULER_WORKER_SCHEDULER_IMPL_H_ | 5 #ifndef CONTENT_CHILD_SCHEDULER_WORKER_SCHEDULER_IMPL_H_ |
6 #define CONTENT_CHILD_SCHEDULER_WORKER_SCHEDULER_IMPL_H_ | 6 #define CONTENT_CHILD_SCHEDULER_WORKER_SCHEDULER_IMPL_H_ |
7 | 7 |
8 #include "content/child/scheduler/worker_scheduler.h" | 8 #include "content/child/scheduler/worker_scheduler.h" |
9 #include "content/child/scheduler/scheduler_helper.h" | 9 #include "content/child/scheduler/scheduler_helper.h" |
10 | 10 |
(...skipping 12 matching lines...) Expand all Loading... |
23 public SchedulerHelper::SchedulerHelperDelegate { | 23 public SchedulerHelper::SchedulerHelperDelegate { |
24 public: | 24 public: |
25 explicit WorkerSchedulerImpl( | 25 explicit WorkerSchedulerImpl( |
26 scoped_refptr<NestableSingleThreadTaskRunner> main_task_runner); | 26 scoped_refptr<NestableSingleThreadTaskRunner> main_task_runner); |
27 ~WorkerSchedulerImpl() override; | 27 ~WorkerSchedulerImpl() override; |
28 | 28 |
29 // WorkerScheduler implementation: | 29 // WorkerScheduler implementation: |
30 scoped_refptr<base::SingleThreadTaskRunner> DefaultTaskRunner() override; | 30 scoped_refptr<base::SingleThreadTaskRunner> DefaultTaskRunner() override; |
31 scoped_refptr<SingleThreadIdleTaskRunner> IdleTaskRunner() override; | 31 scoped_refptr<SingleThreadIdleTaskRunner> IdleTaskRunner() override; |
32 bool CanExceedIdleDeadlineIfRequired() const override; | 32 bool CanExceedIdleDeadlineIfRequired() const override; |
| 33 bool ShouldYieldForHighPriorityWork() override; |
33 void AddTaskObserver(base::MessageLoop::TaskObserver* task_observer) override; | 34 void AddTaskObserver(base::MessageLoop::TaskObserver* task_observer) override; |
34 void RemoveTaskObserver( | 35 void RemoveTaskObserver( |
35 base::MessageLoop::TaskObserver* task_observer) override; | 36 base::MessageLoop::TaskObserver* task_observer) override; |
36 void Init() override; | 37 void Init() override; |
37 void Shutdown() override; | 38 void Shutdown() override; |
38 | 39 |
39 void SetTimeSourceForTesting(scoped_refptr<cc::TestNowSource> time_source); | 40 void SetTimeSourceForTesting(scoped_refptr<cc::TestNowSource> time_source); |
40 void SetWorkBatchSizeForTesting(size_t work_batch_size); | 41 void SetWorkBatchSizeForTesting(size_t work_batch_size); |
41 base::TimeTicks CurrentIdleTaskDeadlineForTesting() const; | 42 base::TimeTicks CurrentIdleTaskDeadlineForTesting() const; |
42 | 43 |
43 protected: | 44 protected: |
44 // SchedulerHelperDelegate implementation: | 45 // SchedulerHelperDelegate implementation: |
45 bool CanEnterLongIdlePeriod( | 46 bool CanEnterLongIdlePeriod( |
46 base::TimeTicks now, | 47 base::TimeTicks now, |
47 base::TimeDelta* next_long_idle_period_delay_out) override; | 48 base::TimeDelta* next_long_idle_period_delay_out) override; |
48 void IsNotQuiescent() override {} | 49 void IsNotQuiescent() override {} |
49 | 50 |
50 private: | 51 private: |
51 void MaybeStartLongIdlePeriod(); | 52 void MaybeStartLongIdlePeriod(); |
52 | 53 |
53 SchedulerHelper helper_; | 54 SchedulerHelper helper_; |
54 bool initialized_; | 55 bool initialized_; |
55 | 56 |
56 DISALLOW_COPY_AND_ASSIGN(WorkerSchedulerImpl); | 57 DISALLOW_COPY_AND_ASSIGN(WorkerSchedulerImpl); |
57 }; | 58 }; |
58 | 59 |
59 } // namespace content | 60 } // namespace content |
60 | 61 |
61 #endif // CONTENT_CHILD_SCHEDULER_WORKER_SCHEDULER_IMPL_H_ | 62 #endif // CONTENT_CHILD_SCHEDULER_WORKER_SCHEDULER_IMPL_H_ |
OLD | NEW |