Index: base/pending_task.h |
diff --git a/base/pending_task.h b/base/pending_task.h |
new file mode 100644 |
index 0000000000000000000000000000000000000000..90ed5016fb4e65a948712d80b6ec9973c83c56b4 |
--- /dev/null |
+++ b/base/pending_task.h |
@@ -0,0 +1,61 @@ |
+// Copyright (c) 2011 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 PENDING_TASK_H_ |
+#define PENDING_TASK_H_ |
+#pragma once |
+ |
+#include <queue> |
+ |
+#include "base/callback.h" |
+#include "base/location.h" |
+#include "base/profiler/tracked_time.h" |
+#include "base/time.h" |
+#include "base/tracking_info.h" |
+ |
+namespace tracked_objects { |
+class Births; |
+} |
+ |
+namespace base { |
+ |
+// Contains data about a pending task. Stored in TaskQueue and DelayedTaskQueue |
+// for use by classes that queue and execute tasks. |
+struct PendingTask : public base::TrackingInfo { |
+ PendingTask(const tracked_objects::Location& posted_from, |
+ const base::Closure& task); |
+ PendingTask(const tracked_objects::Location& posted_from, |
+ const base::Closure& task, |
+ base::TimeTicks delayed_run_time, |
+ bool nestable); |
+ ~PendingTask(); |
+ |
+ // Used to support sorting. |
+ bool operator<(const PendingTask& other) const; |
+ |
+ // The task to run. |
+ base::Closure task; |
+ |
+ // The site this PendingTask was posted from. |
+ tracked_objects::Location posted_from; |
+ |
+ // Secondary sort key for run time. |
+ int sequence_num; |
+ |
+ // OK to dispatch from a nested loop. |
+ bool nestable; |
+}; |
+ |
+// Wrapper around std::queue specialized for PendingTask which adds a Swap |
+// helper method. |
+class TaskQueue : public std::queue<PendingTask> { |
awong
2011/11/14 21:39:31
I don't think you can inherit from queue<>. The d
James Hawkins
2011/11/14 21:45:22
Caveat: This code is directly cut-pasted from Mess
|
+ public: |
+ void Swap(TaskQueue* queue); |
+}; |
+ |
+typedef std::priority_queue<PendingTask> DelayedTaskQueue; |
+ |
+} // namespace base |
+ |
+#endif // PENDING_TASK_H_ |