Implementation of PostTaskAndReply() in MessageLoopProxy and BrowserThread.

base/task.cc

 // Copyright (c) 2011 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.
 
 #include "base/task.h"
 
+#include "base/bind.h"
+
 Task::Task() {
 }
 
 Task::~Task() {
 }
 
 CancelableTask::CancelableTask() {
 }
 
 CancelableTask::~CancelableTask() {
@@ skipping 10 matching lines @@
     delete task_;
   }
 }
 
 Task* ScopedTaskRunner::Release() {
   Task* tmp = task_;
   task_ = NULL;
   return tmp;
 }
 
+namespace internal {
+
+PostTaskAndReplyRelay::PostTaskAndReplyRelay(const Closure& task,
+                                             const Closure& reply)
+    : task_(task),
+      reply_(reply),
+      origin_loop_(MessageLoop::Current()) {
+}
+
+PostTaskAndReplyRelay::~PostTaskAndReplyRelay() {
+  DCHECK(origin_loop_ == MessageLoop::Current());
+}
+
+void PostTaskAndReplyRelay::Run() {
+  task_.Run();
+  origin_loop_->PostTask(

[darin (slow to review), 2011/07/01 04:15:32]

what if the origin thread is already gone?  i suspect you need to use a
MessageLoopProxy instead.

[willchan no longer on Chromium, 2011/07/01 15:13:54]

Yes, MessageLoopProxy FTW.

[awong, 2011/07/02 00:36:57]

Done.

+      base::Bind(&PostTaskAndReplyRelay::RunReplyAndSelfDestruct,

[willchan no longer on Chromium, 2011/07/01 15:13:54]

We're already in base::, so the prefix probably isn't necessary.

[awong, 2011/07/02 00:36:57]

Done.

+                 base::Unretained(this)));
+}
+
+void PostTaskAndReplyRelay::RunReplyAndSelfDestruct() {
+  reply_.Run();
+  delete this;
+}
+}  // namespace internal

[darin (slow to review), 2011/07/01 04:15:32]

nit: add a new line above the close of the namespace

[awong, 2011/07/02 00:36:57]

Done.

+
+
 }  // namespace base