diff --git a/webrtc/base/asyncinvoker-inl.h b/webrtc/base/asyncinvoker-inl.h
index 733cb0e797..e208ee97da 100644
--- a/webrtc/base/asyncinvoker-inl.h
+++ b/webrtc/base/asyncinvoker-inl.h
@@ -29,10 +29,11 @@ class AsyncInvoker;
 // lifetime can be independent of AsyncInvoker.
 class AsyncClosure : public RefCountInterface {
  public:
-  virtual ~AsyncClosure() {}
   // Runs the asynchronous task, and triggers a callback to the calling
   // thread if needed. Should be called from the target thread.
   virtual void Execute() = 0;
+ protected:
+  virtual ~AsyncClosure() {}
 };
 
 // Simple closure that doesn't trigger a callback for the calling thread.
diff --git a/webrtc/base/asyncinvoker.cc b/webrtc/base/asyncinvoker.cc
index ee423f1105..3ccdc4bb4d 100644
--- a/webrtc/base/asyncinvoker.cc
+++ b/webrtc/base/asyncinvoker.cc
@@ -52,12 +52,11 @@ void AsyncInvoker::Flush(Thread* thread, uint32 id /*= MQID_ANY*/) {
   }
 }
 
-void AsyncInvoker::DoInvoke(Thread* thread, AsyncClosure* closure,
+void AsyncInvoker::DoInvoke(Thread* thread,
+                            const scoped_refptr<AsyncClosure>& closure,
                             uint32 id) {
   if (destroying_) {
     LOG(LS_WARNING) << "Tried to invoke while destroying the invoker.";
-    // Since this call transwers ownership of |closure|, we clean it up here.
-    delete closure;
     return;
   }
   thread->Post(this, id, new ScopedRefMessageData<AsyncClosure>(closure));
diff --git a/webrtc/base/asyncinvoker.h b/webrtc/base/asyncinvoker.h
index ee9a03c80a..e4591a1408 100644
--- a/webrtc/base/asyncinvoker.h
+++ b/webrtc/base/asyncinvoker.h
@@ -77,8 +77,8 @@ class AsyncInvoker : public MessageHandler {
   void AsyncInvoke(Thread* thread,
                    const FunctorT& functor,
                    uint32 id = 0) {
-    AsyncClosure* closure =
-        new RefCountedObject<FireAndForgetAsyncClosure<FunctorT> >(functor);
+    scoped_refptr<AsyncClosure> closure(
+        new RefCountedObject<FireAndForgetAsyncClosure<FunctorT> >(functor));
     DoInvoke(thread, closure, id);
   }
 
@@ -89,9 +89,9 @@ class AsyncInvoker : public MessageHandler {
                    void (HostT::*callback)(ReturnT),
                    HostT* callback_host,
                    uint32 id = 0) {
-    AsyncClosure* closure =
+    scoped_refptr<AsyncClosure> closure(
         new RefCountedObject<NotifyingAsyncClosure<ReturnT, FunctorT, HostT> >(
-            this, Thread::Current(), functor, callback, callback_host);
+            this, Thread::Current(), functor, callback, callback_host));
     DoInvoke(thread, closure, id);
   }
 
@@ -103,9 +103,9 @@ class AsyncInvoker : public MessageHandler {
                    void (HostT::*callback)(),
                    HostT* callback_host,
                    uint32 id = 0) {
-    AsyncClosure* closure =
+    scoped_refptr<AsyncClosure> closure(
         new RefCountedObject<NotifyingAsyncClosure<void, FunctorT, HostT> >(
-            this, Thread::Current(), functor, callback, callback_host);
+            this, Thread::Current(), functor, callback, callback_host));
     DoInvoke(thread, closure, id);
   }
 
@@ -121,7 +121,8 @@ class AsyncInvoker : public MessageHandler {
 
  private:
   virtual void OnMessage(Message* msg);
-  void DoInvoke(Thread* thread, AsyncClosure* closure, uint32 id);
+  void DoInvoke(Thread* thread, const scoped_refptr<AsyncClosure>& closure,
+                uint32 id);
 
   bool destroying_;