Relanding: Use std::unique_ptr instead of rtc::scoped_refptr in AsyncInvoker.

webrtc/base/asyncinvoker.h

 /*
  *  Copyright 2014 The WebRTC Project Authors. All rights reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
 #ifndef WEBRTC_BASE_ASYNCINVOKER_H_
 #define WEBRTC_BASE_ASYNCINVOKER_H_
 
+#include <memory>
+#include <utility>
+
 #include "webrtc/base/asyncinvoker-inl.h"
 #include "webrtc/base/bind.h"
 #include "webrtc/base/constructormagic.h"
 #include "webrtc/base/sigslot.h"
-#include "webrtc/base/scopedptrcollection.h"
 #include "webrtc/base/thread.h"
 
 namespace rtc {
 
 // Invokes function objects (aka functors) asynchronously on a Thread, and
 // owns the lifetime of calls (ie, when this object is destroyed, calls in
 // flight are cancelled). AsyncInvoker can optionally execute a user-specified
 // function when the asynchronous call is complete, or operates in
 // fire-and-forget mode otherwise.
 //
@@ skipping 43 matching lines @@
   AsyncInvoker();
   ~AsyncInvoker() override;
 
   // Call |functor| asynchronously on |thread|, with no callback upon
   // completion. Returns immediately.
   template <class ReturnT, class FunctorT>
   void AsyncInvoke(const Location& posted_from,
                    Thread* thread,
                    const FunctorT& functor,
                    uint32_t id = 0) {
-    scoped_refptr<AsyncClosure> closure(
-        new RefCountedObject<FireAndForgetAsyncClosure<FunctorT> >(functor));
-    DoInvoke(posted_from, thread, closure, id);
+    std::unique_ptr<AsyncClosure> closure(
+        new FireAndForgetAsyncClosure<FunctorT>(functor));
+    DoInvoke(posted_from, thread, std::move(closure), id);
   }
 
   // Call |functor| asynchronously on |thread| with |delay_ms|, with no callback
   // upon completion. Returns immediately.
   template <class ReturnT, class FunctorT>
   void AsyncInvokeDelayed(const Location& posted_from,
                           Thread* thread,
                           const FunctorT& functor,
                           uint32_t delay_ms,
                           uint32_t id = 0) {
-    scoped_refptr<AsyncClosure> closure(
-        new RefCountedObject<FireAndForgetAsyncClosure<FunctorT> >(functor));
-    DoInvokeDelayed(posted_from, thread, closure, delay_ms, id);
+    std::unique_ptr<AsyncClosure> closure(
+        new FireAndForgetAsyncClosure<FunctorT>(functor));
+    DoInvokeDelayed(posted_from, thread, std::move(closure), delay_ms, id);
   }
 
   // Call |functor| asynchronously on |thread|, calling |callback| when done.
   // Uses a separate Location for |callback_posted_from| so that the functor
   // invoke and the callback invoke can be differentiated.
   template <class ReturnT, class FunctorT, class HostT>
   void AsyncInvoke(const Location& posted_from,
                    const Location& callback_posted_from,
                    Thread* thread,
                    const FunctorT& functor,
                    void (HostT::*callback)(ReturnT),
                    HostT* callback_host,
                    uint32_t id = 0) {
-    scoped_refptr<AsyncClosure> closure(
-        new RefCountedObject<NotifyingAsyncClosure<ReturnT, FunctorT, HostT> >(
+    std::unique_ptr<AsyncClosure> closure(
+        new NotifyingAsyncClosure<ReturnT, FunctorT, HostT>(
             this, callback_posted_from, Thread::Current(), functor, callback,
             callback_host));
-    DoInvoke(posted_from, thread, closure, id);
+    DoInvoke(posted_from, thread, std::move(closure), id);
   }
 
   // Call |functor| asynchronously on |thread|, calling |callback| when done.
   // Uses a separate Location for |callback_posted_from| so that the functor
   // invoke and the callback invoke can be differentiated.
   // Overloaded for void return.
   template <class ReturnT, class FunctorT, class HostT>
   void AsyncInvoke(const Location& posted_from,
                    const Location& callback_posted_from,
                    Thread* thread,
                    const FunctorT& functor,
                    void (HostT::*callback)(),
                    HostT* callback_host,
                    uint32_t id = 0) {
-    scoped_refptr<AsyncClosure> closure(
-        new RefCountedObject<NotifyingAsyncClosure<void, FunctorT, HostT> >(
+    std::unique_ptr<AsyncClosure> closure(
+        new NotifyingAsyncClosure<void, FunctorT, HostT>(
             this, callback_posted_from, Thread::Current(), functor, callback,
             callback_host));
-    DoInvoke(posted_from, thread, closure, id);
+    DoInvoke(posted_from, thread, std::move(closure), id);
   }
 
   // Synchronously execute on |thread| all outstanding calls we own
   // that are pending on |thread|, and wait for calls to complete
   // before returning. Optionally filter by message id.
   // The destructor will not wait for outstanding calls, so if that
   // behavior is desired, call Flush() before destroying this object.
   void Flush(Thread* thread, uint32_t id = MQID_ANY);
 
   // Signaled when this object is destructed.
   sigslot::signal0<> SignalInvokerDestroyed;
 
  private:
   void OnMessage(Message* msg) override;
   void DoInvoke(const Location& posted_from,
                 Thread* thread,
-                const scoped_refptr<AsyncClosure>& closure,
+                std::unique_ptr<AsyncClosure> closure,
                 uint32_t id);
   void DoInvokeDelayed(const Location& posted_from,
                        Thread* thread,
-                       const scoped_refptr<AsyncClosure>& closure,
+                       std::unique_ptr<AsyncClosure> closure,
                        uint32_t delay_ms,
                        uint32_t id);
   bool destroying_;
 
   RTC_DISALLOW_COPY_AND_ASSIGN(AsyncInvoker);
 };
 
 // Similar to AsyncInvoker, but guards against the Thread being destroyed while
 // there are outstanding dangling pointers to it. It will connect to the current
 // thread in the constructor, and will get notified when that thread is
@@ skipping 80 matching lines @@
   void ThreadDestroyed();
 
   CriticalSection crit_;
   Thread* thread_ GUARDED_BY(crit_);
   AsyncInvoker invoker_ GUARDED_BY(crit_);
 };
 
 }  // namespace rtc
 
 #endif  // WEBRTC_BASE_ASYNCINVOKER_H_