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

Unified Diff: components/scheduler/base/task_queue_impl.h

Issue 1370343002: Revert of scheduler: Add a base directory (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 3 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « components/scheduler/base/task_queue.cc ('k') | components/scheduler/base/task_queue_impl.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: components/scheduler/base/task_queue_impl.h
diff --git a/components/scheduler/base/task_queue_impl.h b/components/scheduler/base/task_queue_impl.h
deleted file mode 100644
index 8e2fa6340611438c5ce4d653d0c63b6f5aa64d8d..0000000000000000000000000000000000000000
--- a/components/scheduler/base/task_queue_impl.h
+++ /dev/null
@@ -1,212 +0,0 @@
-// Copyright 2015 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#ifndef CONTENT_RENDERER_SCHEDULER_BASE_TASK_QUEUE_IMPL_H_
-#define CONTENT_RENDERER_SCHEDULER_BASE_TASK_QUEUE_IMPL_H_
-
-#include <set>
-
-#include "base/pending_task.h"
-#include "base/threading/thread_checker.h"
-#include "base/trace_event/trace_event.h"
-#include "base/trace_event/trace_event_argument.h"
-#include "components/scheduler/base/lazy_now.h"
-#include "components/scheduler/base/task_queue.h"
-#include "components/scheduler/scheduler_export.h"
-
-namespace scheduler {
-class TaskQueueManager;
-
-namespace internal {
-
-class SCHEDULER_EXPORT TaskQueueImpl final : public TaskQueue {
- public:
- TaskQueueImpl(TaskQueueManager* task_queue_manager,
- const Spec& spec,
- const char* disabled_by_default_tracing_category,
- const char* disabled_by_default_verbose_tracing_category);
-
- class SCHEDULER_EXPORT Task : public base::PendingTask {
- public:
- Task();
- Task(const tracked_objects::Location& posted_from,
- const base::Closure& task,
- int sequence_number,
- bool nestable);
-
- int enqueue_order() const {
-#ifndef NDEBUG
- DCHECK(enqueue_order_set_);
-#endif
- return enqueue_order_;
- }
-
- void set_enqueue_order(int enqueue_order) {
-#ifndef NDEBUG
- DCHECK(!enqueue_order_set_);
- enqueue_order_set_ = true;
-#endif
- enqueue_order_ = enqueue_order;
- }
-
- private:
-#ifndef NDEBUG
- bool enqueue_order_set_;
-#endif
- // Similar to sequence number, but the |enqueue_order| is set by
- // EnqueueTasksLocked and is not initially defined for delayed tasks until
- // they are enqueued on the |incoming_queue_|.
- int enqueue_order_;
- };
-
- // TaskQueue implementation.
- void UnregisterTaskQueue() override;
- bool RunsTasksOnCurrentThread() const override;
- bool PostDelayedTask(const tracked_objects::Location& from_here,
- const base::Closure& task,
- base::TimeDelta delay) override;
- bool PostNonNestableDelayedTask(const tracked_objects::Location& from_here,
- const base::Closure& task,
- base::TimeDelta delay) override;
- bool PostDelayedTaskAt(const tracked_objects::Location& from_here,
- const base::Closure& task,
- base::TimeTicks desired_run_time) override;
-
- bool IsQueueEnabled() const override;
- QueueState GetQueueState() const override;
- void SetQueuePriority(QueuePriority priority) override;
- void PumpQueue() override;
- void SetPumpPolicy(PumpPolicy pump_policy) override;
- void AddTaskObserver(base::MessageLoop::TaskObserver* task_observer) override;
- void RemoveTaskObserver(
- base::MessageLoop::TaskObserver* task_observer) override;
-
- bool NextPendingDelayedTaskRunTime(
- base::TimeTicks* next_pending_delayed_task);
-
- void UpdateWorkQueue(LazyNow* lazy_now,
- bool should_trigger_wakeup,
- const Task* previous_task);
- Task TakeTaskFromWorkQueue();
-
- std::queue<Task>& work_queue() { return work_queue_; }
-
- WakeupPolicy wakeup_policy() const {
- DCHECK(main_thread_checker_.CalledOnValidThread());
- return wakeup_policy_;
- }
-
- const char* GetName() const override;
-
- void AsValueInto(base::trace_event::TracedValue* state) const;
-
- size_t get_task_queue_set_index() const { return set_index_; }
-
- void set_task_queue_set_index(size_t set_index) { set_index_ = set_index; }
-
- // If the work queue isn't empty, |enqueue_order| gets set to the enqueue
- // order of the front task and the function returns true. Otherwise the
- // function returns false.
- bool GetWorkQueueFrontTaskEnqueueOrder(int* enqueue_order) const;
-
- bool GetQuiescenceMonitored() const { return should_monitor_quiescence_; }
- bool GetShouldNotifyObservers() const { return should_notify_observers_; }
-
- void NotifyWillProcessTask(const base::PendingTask& pending_task);
- void NotifyDidProcessTask(const base::PendingTask& pending_task);
-
- // Delayed task posted to the underlying run loop, which locks |lock_| and
- // calls MoveReadyDelayedTasksToIncomingQueueLocked to process dealyed tasks
- // that need to be run now. Thread safe, but in practice it's always called
- // from the main thread.
- void MoveReadyDelayedTasksToIncomingQueue(LazyNow* lazy_now);
-
- // Test support functions. These should not be used in production code.
- void PushTaskOntoWorkQueueForTest(const Task& task);
- void PopTaskFromWorkQueueForTest();
- size_t WorkQueueSizeForTest() const { return work_queue_.size(); }
-
- // Can be called on any thread.
- static const char* PumpPolicyToString(TaskQueue::PumpPolicy pump_policy);
-
- // Can be called on any thread.
- static const char* WakeupPolicyToString(
- TaskQueue::WakeupPolicy wakeup_policy);
-
- // Can be called on any thread.
- static const char* PriorityToString(TaskQueue::QueuePriority priority);
-
- private:
- enum class TaskType {
- NORMAL,
- NON_NESTABLE,
- };
-
- ~TaskQueueImpl() override;
-
- bool PostDelayedTaskImpl(const tracked_objects::Location& from_here,
- const base::Closure& task,
- base::TimeDelta delay,
- TaskType task_type);
- bool PostDelayedTaskLocked(LazyNow* lazy_now,
- const tracked_objects::Location& from_here,
- const base::Closure& task,
- base::TimeTicks desired_run_time,
- TaskType task_type);
-
- // Enqueues any delayed tasks which should be run now on the incoming_queue_
- // and calls ScheduleDelayedWorkLocked to ensure future tasks are scheduled.
- // Must be called with |lock_| locked.
- void MoveReadyDelayedTasksToIncomingQueueLocked(LazyNow* lazy_now);
-
- void PumpQueueLocked();
- bool TaskIsOlderThanQueuedTasks(const Task* task);
- bool ShouldAutoPumpQueueLocked(bool should_trigger_wakeup,
- const Task* previous_task);
-
- // Push the task onto the |incoming_queue_| and for auto pumped queues it
- // calls MaybePostDoWorkOnMainRunner if the incomming queue was empty.
- void EnqueueTaskLocked(const Task& pending_task);
-
- // Push the task onto the |incoming_queue_| and allocates an
- // enqueue_order for it based on |enqueue_order_policy|. Does not call
- // MaybePostDoWorkOnMainRunner!
- void EnqueueDelayedTaskLocked(const Task& pending_task);
-
- void TraceQueueSize(bool is_locked) const;
- static void QueueAsValueInto(const std::queue<Task>& queue,
- base::trace_event::TracedValue* state);
- static void QueueAsValueInto(const std::priority_queue<Task>& queue,
- base::trace_event::TracedValue* state);
- static void TaskAsValueInto(const Task& task,
- base::trace_event::TracedValue* state);
-
- // This lock protects all members in the contigious block below.
- // TODO(alexclarke): Group all the members protected by the lock into a struct
- mutable base::Lock lock_;
- base::PlatformThreadId thread_id_;
- TaskQueueManager* task_queue_manager_;
- std::queue<Task> incoming_queue_;
- PumpPolicy pump_policy_;
- std::priority_queue<Task> delayed_task_queue_;
-
- const char* name_;
- const char* disabled_by_default_tracing_category_;
- const char* disabled_by_default_verbose_tracing_category_;
-
- base::ThreadChecker main_thread_checker_;
- std::queue<Task> work_queue_;
- base::ObserverList<base::MessageLoop::TaskObserver> task_observers_;
- WakeupPolicy wakeup_policy_;
- size_t set_index_;
- bool should_monitor_quiescence_;
- bool should_notify_observers_;
-
- DISALLOW_COPY_AND_ASSIGN(TaskQueueImpl);
-};
-
-} // namespace internal
-} // namespace scheduler
-
-#endif // CONTENT_RENDERER_SCHEDULER_BASE_TASK_QUEUE_IMPL_H_
« no previous file with comments | « components/scheduler/base/task_queue.cc ('k') | components/scheduler/base/task_queue_impl.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698