Add WebTaskRunner::postCancellableTask

third_party/WebKit/public/platform/WebTaskRunner.h

 // 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 WebTaskRunner_h
 #define WebTaskRunner_h
 
 #include "WebCommon.h"
 #include "base/callback_forward.h"
 #include "public/platform/WebTraceLocation.h"
 #include <memory>
 
 #ifdef INSIDE_BLINK
 #include "wtf/Functional.h"
+#include "wtf/RefCounted.h"
+#include "wtf/WeakPtr.h"
 #endif
 
 namespace base {
 class SingleThreadTaskRunner;
 }
 
 namespace blink {
 
 using SingleThreadTaskRunner = base::SingleThreadTaskRunner;
 
+#ifdef INSIDE_BLINK
+
+class BLINK_PLATFORM_EXPORT TaskHandle
+    : public WTF::ThreadSafeRefCounted<TaskHandle> {
+ public:
+  // Returns true if the task will run later. Returns false if the task is
+  // cancelled or the task is ran already.

[haraken, 2016/10/20 17:07:37]

run (or completed)

[tzik, 2016/10/25 07:03:52]

Done.

+  // This function is not thread safe. Call this on the thread that has posted
+  // the task.
+  bool isActive() const;
+
+  // Cancels the task invocation. Do nothing if the task is cancelled or ran

[haraken, 2016/10/20 17:07:37]

Ditto.

[tzik, 2016/10/25 07:03:52]

Done.

+  // already.
+  // This function is not thread safe. Call this on the thread that has posted
+  // the task.
+  void cancel();
+
+  ~TaskHandle();
+
+ private:
+  class CancelOnScopeOut;
+  friend class WebTaskRunner;
+
+  explicit TaskHandle(std::unique_ptr<WTF::Closure> task);
+  void run(const ClearOnScopeOut&);
+  WTF::WeakPtr<TaskHandle> asWeakPtr();
+
+  std::unique_ptr<WTF::Closure> m_task;
+  WTF::WeakPtrFactory<TaskHandle> m_weakPtrFactory;
+
+  DISALLOW_COPY_AND_ASSIGN(TaskHandle);
+};
+
+#endif
+
 // The blink representation of a chromium SingleThreadTaskRunner.
 class BLINK_PLATFORM_EXPORT WebTaskRunner {
  public:
   virtual ~WebTaskRunner() {}
 
   class BLINK_PLATFORM_EXPORT Task {
    public:
     virtual ~Task() {}
     virtual void run() = 0;
   };
@@ skipping 50 matching lines @@
   void postTask(const WebTraceLocation&, std::unique_ptr<CrossThreadClosure>);
   void postDelayedTask(const WebTraceLocation&,
                        std::unique_ptr<CrossThreadClosure>,
                        long long delayMs);
 
   // For same-thread posting. Must be called from the associated WebThread.
   void postTask(const WebTraceLocation&, std::unique_ptr<WTF::Closure>);
   void postDelayedTask(const WebTraceLocation&,
                        std::unique_ptr<WTF::Closure>,
                        long long delayMs);
+
+  // For same-thread cancellable task posting. Returns a TaskHandle object for
+  // cancellation.
+  RefPtr<TaskHandle> postCancellableTask(const WebTraceLocation&,
+                                         std::unique_ptr<WTF::Closure>);
+  RefPtr<TaskHandle> postDelayedCancellableTask(const WebTraceLocation&,
+                                                std::unique_ptr<WTF::Closure>,
+                                                long long delayMs);
 #endif
 };
 
 }  // namespace blink
 
 #endif  // WebTaskRunner_h