Index: base/message_loop/message_loop.h |
diff --git a/base/message_loop/message_loop.h b/base/message_loop/message_loop.h |
index 1b6d407241acf9114495af249ba8aeb5428fae22..3a3b657243c80bbd35f96466c7cd760d1d10694d 100644 |
--- a/base/message_loop/message_loop.h |
+++ b/base/message_loop/message_loop.h |
@@ -12,6 +12,7 @@ |
#include "base/basictypes.h" |
#include "base/callback_forward.h" |
#include "base/debug/task_annotator.h" |
+#include "base/gtest_prod_util.h" |
#include "base/location.h" |
#include "base/memory/ref_counted.h" |
#include "base/memory/scoped_ptr.h" |
@@ -37,6 +38,7 @@ |
namespace base { |
+class BindableSingleThreadTaskRunner; |
class HistogramBase; |
class RunLoop; |
class ThreadTaskRunnerHandle; |
@@ -296,9 +298,17 @@ class BASE_EXPORT MessageLoop : public MessagePump::Delegate { |
const std::string& thread_name() const { return thread_name_; } |
// Gets the TaskRunner associated with this message loop. |
- // TODO(skyostil): Change this to return a const reference to a refptr |
- // once the internal type matches what is being returned (crbug.com/465354). |
- scoped_refptr<SingleThreadTaskRunner> task_runner() { return task_runner_; } |
+ scoped_refptr<SingleThreadTaskRunner> task_runner() { |
+ return task_runner_; |
+ } |
+ |
+ // Sets a new TaskRunner for this message loop and returns the previous one. |
+ // If the message loop was already bound to a thread, this function must be |
+ // called on that thread and the task runner must also belong to that thread. |
+ // Note that changing the task runner will also affect the |
+ // ThreadTaskRunnerHandle for the target thread. |
+ scoped_refptr<BindableSingleThreadTaskRunner> SwapTaskRunner( |
+ scoped_refptr<BindableSingleThreadTaskRunner> task_runner); |
// Enables or disables the recursive task processing. This happens in the case |
// of recursive message loops. Some unwanted message loop may occurs when |
@@ -401,6 +411,7 @@ class BASE_EXPORT MessageLoop : public MessagePump::Delegate { |
friend class internal::IncomingTaskQueue; |
friend class ScheduleWorkTest; |
friend class Thread; |
+ FRIEND_TEST_ALL_PREFIXES(MessageLoopTest, SwapTaskRunnerBeforeBinding); |
using MessagePumpFactoryCallback = Callback<scoped_ptr<MessagePump>()>; |
@@ -523,7 +534,7 @@ class BASE_EXPORT MessageLoop : public MessagePump::Delegate { |
scoped_refptr<internal::IncomingTaskQueue> incoming_task_queue_; |
// The task runner associated with this message loop. |
- scoped_refptr<internal::MessageLoopTaskRunner> task_runner_; |
+ scoped_refptr<BindableSingleThreadTaskRunner> task_runner_; |
scoped_ptr<ThreadTaskRunnerHandle> thread_task_runner_handle_; |
template <class T, class R> friend class base::subtle::DeleteHelperInternal; |