| 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_RENDERER_SCHEDULER_RENDERER_TASK_QUEUE_SELECTOR_H_ | |
| 6 #define CONTENT_RENDERER_SCHEDULER_RENDERER_TASK_QUEUE_SELECTOR_H_ | |
| 7 | |
| 8 #include <set> | |
| 9 | |
| 10 #include "base/compiler_specific.h" | |
| 11 #include "base/threading/thread_checker.h" | |
| 12 #include "content/common/content_export.h" | |
| 13 #include "content/renderer/scheduler/task_queue_selector.h" | |
| 14 | |
| 15 namespace content { | |
| 16 | |
| 17 // A RendererTaskQueueSelector is a TaskQueueSelector which is used by the | |
| 18 // RendererScheduler to enable prioritization of particular task queues. | |
| 19 class CONTENT_EXPORT RendererTaskQueueSelector | |
| 20 : NON_EXPORTED_BASE(public TaskQueueSelector) { | |
| 21 public: | |
| 22 enum QueuePriority { | |
| 23 // Queues with control priority will run before any other queue, and will | |
| 24 // explicitly starve other queues. Typically this should only be used for | |
| 25 // private queues which perform control operations. | |
| 26 CONTROL_PRIORITY, | |
| 27 // Queues with high priority will be selected preferentially over normal or | |
| 28 // best effort queues. The selector will ensure that high priority queues | |
| 29 // cannot completely starve normal priority queues. | |
| 30 HIGH_PRIORITY, | |
| 31 // Queues with normal priority are the default. | |
| 32 NORMAL_PRIORITY, | |
| 33 // Queues with best effort priority will only be run if all other queues are | |
| 34 // empty. They can be starved by the other queues. | |
| 35 BEST_EFFORT_PRIORITY, | |
| 36 // Must be the last entry. | |
| 37 QUEUE_PRIORITY_COUNT, | |
| 38 FIRST_QUEUE_PRIORITY = CONTROL_PRIORITY, | |
| 39 }; | |
| 40 | |
| 41 RendererTaskQueueSelector(); | |
| 42 ~RendererTaskQueueSelector() override; | |
| 43 | |
| 44 // Set the priority of |queue_index| to |priority|. | |
| 45 void SetQueuePriority(size_t queue_index, QueuePriority priority); | |
| 46 | |
| 47 // Enable the |queue_index| with a priority of |priority|. By default all | |
| 48 // queues are enabled with normal priority. | |
| 49 void EnableQueue(size_t queue_index, QueuePriority priority); | |
| 50 | |
| 51 // Disable the |queue_index|. | |
| 52 void DisableQueue(size_t queue_index); | |
| 53 | |
| 54 // Whether |queue_index| is enabled. | |
| 55 bool IsQueueEnabled(size_t queue_index) const; | |
| 56 | |
| 57 // TaskQueueSelector implementation: | |
| 58 void RegisterWorkQueues( | |
| 59 const std::vector<const base::TaskQueue*>& work_queues) override; | |
| 60 bool SelectWorkQueueToService(size_t* out_queue_index) override; | |
| 61 void AsValueInto(base::trace_event::TracedValue* state) const override; | |
| 62 | |
| 63 private: | |
| 64 // Returns true if queueA contains an older task than queueB. | |
| 65 static bool IsOlder(const base::TaskQueue* queueA, | |
| 66 const base::TaskQueue* queueB); | |
| 67 | |
| 68 // Returns the priority which is next after |priority|. | |
| 69 static QueuePriority NextPriority(QueuePriority priority); | |
| 70 | |
| 71 static const char* PriorityToString(QueuePriority priority); | |
| 72 | |
| 73 // Return true if |out_queue_index| indicates the index of the queue with | |
| 74 // the oldest pending task from the set of queues of |priority|, or | |
| 75 // false if all queues of that priority are empty. | |
| 76 bool ChooseOldestWithPriority(QueuePriority priority, | |
| 77 size_t* out_queue_index) const; | |
| 78 | |
| 79 // Returns true if |queue_index| is enabled with the given |priority|. | |
| 80 bool QueueEnabledWithPriority(size_t queue_index, | |
| 81 QueuePriority priority) const; | |
| 82 | |
| 83 // Called whenever the selector chooses a task queue for execution with the | |
| 84 // priority |priority|. | |
| 85 void DidSelectQueueWithPriority(QueuePriority priority); | |
| 86 | |
| 87 // Number of high priority tasks which can be run before a normal priority | |
| 88 // task should be selected to prevent starvation. | |
| 89 // TODO(rmcilroy): Check if this is a good value. | |
| 90 static const size_t kMaxStarvationTasks = 5; | |
| 91 | |
| 92 base::ThreadChecker main_thread_checker_; | |
| 93 std::vector<const base::TaskQueue*> work_queues_; | |
| 94 std::set<size_t> queue_priorities_[QUEUE_PRIORITY_COUNT]; | |
| 95 size_t starvation_count_; | |
| 96 DISALLOW_COPY_AND_ASSIGN(RendererTaskQueueSelector); | |
| 97 }; | |
| 98 | |
| 99 } // namespace content | |
| 100 | |
| 101 #endif // CONTENT_RENDERER_SCHEDULER_RENDERER_TASK_QUEUE_SELECTOR_H_ | |
| OLD | NEW |