Index: webkit/dom_storage/dom_storage_task_runner.h |
=================================================================== |
--- webkit/dom_storage/dom_storage_task_runner.h (revision 0) |
+++ webkit/dom_storage/dom_storage_task_runner.h (revision 0) |
@@ -0,0 +1,70 @@ |
+// Copyright (c) 2012 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 WEBKIT_DOM_STORAGE_DOM_STORAGE_TASK_RUNNER_ |
+#define WEBKIT_DOM_STORAGE_DOM_STORAGE_TASK_RUNNER_ |
+#pragma once |
+ |
+#include "base/memory/ref_counted.h" |
+#include "base/threading/sequenced_worker_pool.h" |
+ |
+namespace base { |
+class MessageLoopProxy; |
+} |
+ |
+namespace dom_storage { |
+ |
+// Tasks must run serially with respect to one another, but may |
darin (slow to review)
2012/02/04 05:26:07
there's actually work underway by akalin to create
|
+// execute on different OS threads. The base class is implemented |
+// in terms of a MessageLoopProxy for use in testing. |
+class DomStorageTaskRunner |
+ : public base::RefCountedThreadSafe<DomStorageTaskRunner> { |
+ public: |
+ explicit DomStorageTaskRunner(base::MessageLoopProxy* message_loop); |
+ virtual ~DomStorageTaskRunner(); |
+ |
+ // Schedules a task to be run immediately. |
+ virtual void PostTask( |
+ const tracked_objects::Location& from_here, |
+ const base::Closure& task); |
+ |
+ // Schedules a task to be run after a delay. |
+ virtual void PostDelayedTask( |
+ const tracked_objects::Location& from_here, |
+ const base::Closure& task, |
+ base::TimeDelta delay); |
+ |
+ protected: |
+ scoped_refptr<base::MessageLoopProxy> message_loop_; |
+}; |
+ |
+// A derived class that utlizes the SequenceWorkerPool under a |
+// dom_storage specific SequenceToken. The MessageLoopProxy |
+// is used to delay scheduling on the worker pool. |
+class DomStorageWorkerPoolTaskRunner : public DomStorageTaskRunner { |
+ public: |
+ DomStorageWorkerPoolTaskRunner( |
+ base::SequencedWorkerPool* sequenced_worker_pool, |
+ base::MessageLoopProxy* delayed_task_loop); |
+ virtual ~DomStorageWorkerPoolTaskRunner(); |
+ |
+ // Schedules a sequenced worker task to be run immediately. |
+ virtual void PostTask( |
+ const tracked_objects::Location& from_here, |
+ const base::Closure& task) OVERRIDE; |
+ |
+ // Schedules a sequenced worker task to be run after a delay. |
+ virtual void PostDelayedTask( |
+ const tracked_objects::Location& from_here, |
+ const base::Closure& task, |
+ base::TimeDelta delay) OVERRIDE; |
+ |
+ private: |
+ base::SequencedWorkerPool* sequenced_worker_pool_; // not owned |
+ base::SequencedWorkerPool::SequenceToken sequence_token_; |
+}; |
+ |
+} // namespace dom_storage |
+ |
+#endif // WEBKIT_DOM_STORAGE_DOM_STORAGE_TASK_RUNNER_ |
Property changes on: webkit\dom_storage\dom_storage_task_runner.h |
___________________________________________________________________ |
Added: svn:eol-style |
+ LF |