| Index: base/message_loop/incoming_task_queue.cc
|
| diff --git a/base/message_loop/incoming_task_queue.cc b/base/message_loop/incoming_task_queue.cc
|
| index c1ce939b0c4708ac431d80b54a35ee8ef73b314c..067cbb1bf5e984329a953adc29a5f1b80e542b52 100644
|
| --- a/base/message_loop/incoming_task_queue.cc
|
| +++ b/base/message_loop/incoming_task_queue.cc
|
| @@ -109,6 +109,21 @@ void IncomingTaskQueue::WillDestroyCurrentMessageLoop() {
|
| message_loop_ = NULL;
|
| }
|
|
|
| +void IncomingTaskQueue::StartScheduling() {
|
| + AutoLock lock(incoming_queue_lock_);
|
| + DCHECK(!is_ready_for_scheduling_);
|
| + is_ready_for_scheduling_ = true;
|
| + if (!incoming_queue_.empty()) {
|
| + message_loop_->ScheduleWork();
|
| + message_loop_scheduled_ = true;
|
| + }
|
| +}
|
| +
|
| +bool IncomingTaskQueue::empty() {
|
| + AutoLock lock(incoming_queue_lock_);
|
| + return incoming_queue_.empty();
|
| +}
|
| +
|
| IncomingTaskQueue::~IncomingTaskQueue() {
|
| // Verify that WillDestroyCurrentMessageLoop() has been called.
|
| DCHECK(!message_loop_);
|
| @@ -148,7 +163,8 @@ bool IncomingTaskQueue::PostPendingTask(PendingTask* pending_task) {
|
| incoming_queue_.push(*pending_task);
|
| pending_task->task.Reset();
|
|
|
| - if (always_schedule_work_ || (!message_loop_scheduled_ && was_empty)) {
|
| + if (is_ready_for_scheduling_ &&
|
| + (always_schedule_work_ || (!message_loop_scheduled_ && was_empty))) {
|
| // Wake up the message loop.
|
| message_loop_->ScheduleWork();
|
| // After we've scheduled the message loop, we do not need to do so again
|
|
|