[Offline pages] Introduces TaskQueue to serialize tasks that asynchronously access SQLStore

components/offline_pages/core/task.h

Index: components/offline_pages/core/task.h
diff --git a/components/offline_pages/core/task.h b/components/offline_pages/core/task.h
new file mode 100644
index 0000000000000000000000000000000000000000..4d77679ce079cb2ce815f2ef61d01a16952043a4
--- /dev/null
+++ b/components/offline_pages/core/task.h
@@ -0,0 +1,82 @@
+// Copyright 2016 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 COMPONENTS_OFFLINE_PAGES_CORE_TASK_H_
+#define COMPONENTS_OFFLINE_PAGES_CORE_TASK_H_
+
+#include "base/callback.h"
+#include "base/macros.h"
+#include "base/memory/ref_counted.h"
+#include "base/single_thread_task_runner.h"
+
+namespace offline_pages {
+
+// Task interface for consumers of the TaskQueue. Implements a mechanism for
+// task completion.
+//
+// To create your own Task:
+// * Derive your new task from offline_pages::Task.
+// * Implement your task with as many async operations on the controlled
+//   resource as is required. (In general the smaller the task the better.)
+// * Whenever the task is terminated, call |Complete|.
+// * To schedule task for execution call |TaskQueue::AddTask|.
+//
+// If there is a chance that a task callback will come after the task is
+// destroyed, it is up to the task to actually implement mechanism to deal with
+// that, such as using a |base::WeakPtrFactory|.
+class Task {
+ public:
+  // Signature of the method to be called by a task, when its work is done.
+  typedef base::Callback<void(Task*)> TaskCompletionCallback;
+
+  Task();
+  virtual ~Task();
+
+  // Entry point to the task. This is used by the queue to start the task, and
+  // first step of the task should be implemented by overloading this method.
+  // The task should define an additional method for every asynchronous step,
+  // with each step setting up the next step as a callback.
+  // TODO(fgorski): Consider alternative: protected RunImpl(), so that we can
+  // add things like UMA in the Run method.
+  virtual void Run() = 0;
+
+  // Sets the callback normally used by |TaskQueue| for testing. See
+  // |SetTaskCompletionCallback| for details.
+  void SetTaskCompletionCallbackForTesting(
+      scoped_refptr<base::SingleThreadTaskRunner> task_completion_runner,
+      const TaskCompletionCallback& task_completion_callback);
+
+ protected:
+  // Call |TaskComplete| as the last call, before the task is terminated. This
+  // ensures that |TaskQueue| can pick up another task.
+  // |task_completion_callback_| will be scheduled on the provided
+  // |task_completion_runner_|, which means task code is no longer going to be
+  // on stack, when the next call is made.
+  void TaskComplete();
+
+ private:
+  friend class TaskQueue;
+
+  // Allows task queue to Set the |task_completion_callback| and single thread
+  // task |task_completion_runner| that will be used to inform the |TaskQueue|
+  // when the task is done.
+  //
+  // If the task is run outside of the |TaskQueue| and completion callback is
+  // not set, it will also work.
+  void SetTaskCompletionCallback(
+      scoped_refptr<base::SingleThreadTaskRunner> task_completion_runner,
+      const TaskCompletionCallback& task_completion_callback);
+
+  // Completion callback for this task set by |SetTaskCompletionCallback|.
+  TaskCompletionCallback task_completion_callback_;
+  // Task runner for calling completion callback. Set by
+  // |SetTaskCompletionCallback|.
+  scoped_refptr<base::SingleThreadTaskRunner> task_completion_runner_;
+
+  DISALLOW_COPY_AND_ASSIGN(Task);
+};
+
+}  // namespace offline_pages
+
+#endif  // COMPONENTS_OFFLINE_PAGES_CORE_TASK_H_