Run the later parts of startup as UI thread tasks

content/browser/browser_main_loop.cc

 // Copyright (c) 2012 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 "content/browser/browser_main_loop.h"
 
 #include "base/bind.h"
 #include "base/command_line.h"
 #include "base/debug/trace_event.h"
 #include "base/logging.h"
@@ skipping 26 matching lines @@
 #include "content/browser/webui/content_web_ui_controller_factory.h"
 #include "content/browser/webui/url_data_manager.h"
 #include "content/public/browser/browser_main_parts.h"
 #include "content/public/browser/browser_shutdown.h"
 #include "content/public/browser/compositor_util.h"
 #include "content/public/browser/content_browser_client.h"
 #include "content/public/browser/render_process_host.h"
 #include "content/public/common/content_switches.h"
 #include "content/public/common/main_function_params.h"
 #include "content/public/common/result_codes.h"
+#include "content/public/common/startup_task_runner.h"
 #include "crypto/nss_util.h"
 #include "media/audio/audio_manager.h"
 #include "media/base/media.h"
 #include "media/midi/midi_manager.h"
 #include "net/base/network_change_notifier.h"
 #include "net/socket/client_socket_factory.h"
 #include "net/ssl/ssl_config_service.h"
 #include "ui/base/clipboard/clipboard.h"
 
 #if defined(USE_AURA)
@@ skipping 407 matching lines @@
   }
 #endif
 
   if (parsed_command_line_.HasSwitch(switches::kMemoryMetrics)) {
     TRACE_EVENT0("startup", "BrowserMainLoop::Subsystem:MemoryObserver")
     memory_observer_.reset(new MemoryObserver());
     base::MessageLoop::current()->AddTaskObserver(memory_observer_.get());
   }
 }
 
-void BrowserMainLoop::CreateThreads() {
-  TRACE_EVENT0("startup", "BrowserMainLoop::CreateThreads")
+void BrowserMainLoop::CreateThread(size_t thread_id) {
+
+  base::Thread::Options default_options;
+  scoped_ptr<BrowserProcessSubThread>* thread_to_start = NULL;
+  base::Thread::Options* options = &default_options;
+
+  base::Thread::Options io_message_loop_options;
+  io_message_loop_options.message_loop_type = base::MessageLoop::TYPE_IO;
+  base::Thread::Options ui_message_loop_options;
+  ui_message_loop_options.message_loop_type = base::MessageLoop::TYPE_UI;
+
+  switch (thread_id) {
+    case BrowserThread::DB:
+      TRACE_EVENT_BEGIN1("startup",
+                         "BrowserMainLoop::CreateThread:start",
+                         "Thread",
+                         "BrowserThread::DB");
+      thread_to_start = &db_thread_;
+      break;
+    case BrowserThread::FILE_USER_BLOCKING:
+      TRACE_EVENT_BEGIN1("startup",
+                         "BrowserMainLoop::CreateThread:start",
+                         "Thread",
+                         "BrowserThread::FILE_USER_BLOCKING");
+      thread_to_start = &file_user_blocking_thread_;
+      break;
+    case BrowserThread::FILE:
+      TRACE_EVENT_BEGIN1("startup",
+                         "BrowserMainLoop::CreateThread:start",
+                         "Thread",
+                         "BrowserThread::FILE");
+      thread_to_start = &file_thread_;
+#if defined(OS_WIN)
+      // On Windows, the FILE thread needs to be have a UI message loop
+      // which pumps messages in such a way that Google Update can
+      // communicate back to us.
+      options = &ui_message_loop_options;
+#else
+      options = &io_message_loop_options;
+#endif
+      break;
+    case BrowserThread::PROCESS_LAUNCHER:
+      TRACE_EVENT_BEGIN1("startup",
+                         "BrowserMainLoop::CreateThread:start",
+                         "Thread",
+                         "BrowserThread::PROCESS_LAUNCHER");
+      thread_to_start = &process_launcher_thread_;
+      break;
+    case BrowserThread::CACHE:
+      TRACE_EVENT_BEGIN1("startup",
+                         "BrowserMainLoop::CreateThread:start",
+                         "Thread",
+                         "BrowserThread::CACHE");
+      thread_to_start = &cache_thread_;
+      options = &io_message_loop_options;
+      break;
+    case BrowserThread::IO:
+      TRACE_EVENT_BEGIN1("startup",
+                         "BrowserMainLoop::CreateThread:start",
+                         "Thread",
+                         "BrowserThread::IO");
+      thread_to_start = &io_thread_;
+      options = &io_message_loop_options;
+      break;
+    case BrowserThread::UI:
+    case BrowserThread::ID_COUNT:
+    default:
+      NOTREACHED();
+      break;
+  }
+
+  BrowserThread::ID id = static_cast<BrowserThread::ID>(thread_id);
+
+  if (thread_to_start) {
+    (*thread_to_start).reset(new BrowserProcessSubThread(id));
+    (*thread_to_start)->StartWithOptions(*options);
+  } else {
+    NOTREACHED();
+  }
+
+  TRACE_EVENT_END0("startup", "BrowserMainLoop::CreateThread:start");
+}
+
+void BrowserMainLoop::PreCreateThreads() {
 
   if (parts_) {
     TRACE_EVENT0("startup",
         "BrowserMainLoop::CreateThreads:PreCreateThreads");
     result_code_ = parts_->PreCreateThreads();
   }
 
 #if defined(ENABLE_PLUGINS)
   // Prior to any processing happening on the io thread, we create the
   // plugin service as it is predominantly used from the io thread,
   // but must be created on the main thread. The service ctor is
   // inexpensive and does not invoke the io_thread() accessor.
   {
     TRACE_EVENT0("startup", "BrowserMainLoop::CreateThreads:PluginService")
     PluginService::GetInstance()->Init();
   }
 #endif
 
 #if !defined(OS_IOS) && (!defined(GOOGLE_CHROME_BUILD) || defined(OS_ANDROID))
   // Single-process is an unsupported and not fully tested mode, so
   // don't enable it for official Chrome builds (except on Android).
   if (parsed_command_line_.HasSwitch(switches::kSingleProcess))
     RenderProcessHost::SetRunRendererInProcess(true);
 #endif
+}
 
-  if (result_code_ > 0)
-    return;
+void BrowserMainLoop::CreateThreads(
+    const scoped_refptr<StartupTaskRunner>& task_runner) {
+  TRACE_EVENT0("startup", "BrowserMainLoop::CreateThreads")
 
-  base::Thread::Options default_options;
-  base::Thread::Options io_message_loop_options;
-  io_message_loop_options.message_loop_type = base::MessageLoop::TYPE_IO;
-  base::Thread::Options ui_message_loop_options;
-  ui_message_loop_options.message_loop_type = base::MessageLoop::TYPE_UI;
+  task_runner->SetProxy(base::MessageLoop::current()->message_loop_proxy());
+
+  base::Closure pre_create_threads =
+      base::Bind(&BrowserMainLoop::PreCreateThreads, base::Unretained(this));
+  task_runner->AddTask(pre_create_threads);
 
   // Start threads in the order they occur in the BrowserThread::ID
   // enumeration, except for BrowserThread::UI which is the main
   // thread.
   //
   // Must be size_t so we can increment it.
   for (size_t thread_id = BrowserThread::UI + 1;
        thread_id < BrowserThread::ID_COUNT;
        ++thread_id) {
-    scoped_ptr<BrowserProcessSubThread>* thread_to_start = NULL;
-    base::Thread::Options* options = &default_options;
-
-    switch (thread_id) {
-      case BrowserThread::DB:
-        TRACE_EVENT_BEGIN1("startup",
-            "BrowserMainLoop::CreateThreads:start",
-            "Thread", "BrowserThread::DB");
-        thread_to_start = &db_thread_;
-        break;
-      case BrowserThread::FILE_USER_BLOCKING:
-        TRACE_EVENT_BEGIN1("startup",
-            "BrowserMainLoop::CreateThreads:start",
-            "Thread", "BrowserThread::FILE_USER_BLOCKING");
-        thread_to_start = &file_user_blocking_thread_;
-        break;
-      case BrowserThread::FILE:
-        TRACE_EVENT_BEGIN1("startup",
-            "BrowserMainLoop::CreateThreads:start",
-            "Thread", "BrowserThread::FILE");
-        thread_to_start = &file_thread_;
-#if defined(OS_WIN)
-        // On Windows, the FILE thread needs to be have a UI message loop
-        // which pumps messages in such a way that Google Update can
-        // communicate back to us.
-        options = &ui_message_loop_options;
-#else
-        options = &io_message_loop_options;
-#endif
-        break;
-      case BrowserThread::PROCESS_LAUNCHER:
-        TRACE_EVENT_BEGIN1("startup",
-            "BrowserMainLoop::CreateThreads:start",
-            "Thread", "BrowserThread::PROCESS_LAUNCHER");
-        thread_to_start = &process_launcher_thread_;
-        break;
-      case BrowserThread::CACHE:
-        TRACE_EVENT_BEGIN1("startup",
-            "BrowserMainLoop::CreateThreads:start",
-            "Thread", "BrowserThread::CACHE");
-        thread_to_start = &cache_thread_;
-        options = &io_message_loop_options;
-        break;
-      case BrowserThread::IO:
-        TRACE_EVENT_BEGIN1("startup",
-            "BrowserMainLoop::CreateThreads:start",
-            "Thread", "BrowserThread::IO");
-        thread_to_start = &io_thread_;
-        options = &io_message_loop_options;
-        break;
-      case BrowserThread::UI:
-      case BrowserThread::ID_COUNT:
-      default:
-        NOTREACHED();
-        break;
-    }
-
-    BrowserThread::ID id = static_cast<BrowserThread::ID>(thread_id);
-
-    if (thread_to_start) {
-      (*thread_to_start).reset(new BrowserProcessSubThread(id));
-      (*thread_to_start)->StartWithOptions(*options);
-    } else {
-      NOTREACHED();
-    }
-
-    TRACE_EVENT_END0("startup", "BrowserMainLoop::CreateThreads:start");
-
+    base::Closure create_thread = base::Bind(
+        &BrowserMainLoop::CreateThread, base::Unretained(this), thread_id);
+    task_runner->AddTask(create_thread);

[Yaron, 2013/07/23 02:14:03]

To jam's point, the two slow thread inits that I knew of were: IO thread and
webkit deprecated. IO is now async and webkit deprecated is gone, so is this
part still worth it? I know there are other parts of startup where this might
apply but it maybe unnecessary at this granularity.

[aberent, 2013/07/23 13:45:03]

The time for actual thread creation is now trivial (~6ms), but has to happen
after PreCreateThreads, which is the largest single block of work. As such,
PreCreateThreads has to run in a task, so anything following it, including
thread creation, has to run in tasks. I will change this to create all the
threads in a single task, rather than creating a separate task for each thread
creation.

   }
 
-#if !defined(OS_IOS)
-  indexed_db_thread_.reset(new base::Thread("IndexedDB"));
-  indexed_db_thread_->Start();
-#endif
+  base::Closure browser_thread_started = base::Bind(
+      &BrowserMainLoop::BrowserThreadsStarted, base::Unretained(this));
+  task_runner->AddTask(browser_thread_started);
 
-  BrowserThreadsStarted();
+  base::Closure pre_main_message_loop_run = base::Bind(
+      &BrowserMainLoop::PreMainMessageLoopRun, base::Unretained(this));
+  task_runner->AddTask(pre_main_message_loop_run);
 
+  task_runner->StartRunningTasks();
+}
+
+void BrowserMainLoop::PreMainMessageLoopRun() {
   if (parts_) {
     TRACE_EVENT0("startup",
         "BrowserMainLoop::CreateThreads:PreMainMessageLoopRun");
     parts_->PreMainMessageLoopRun();
   }
 
   // If the UI thread blocks, the whole UI is unresponsive.
   // Do not allow disk IO from the UI thread.
   base::ThreadRestrictions::SetIOAllowed(false);
   base::ThreadRestrictions::DisallowWaiting();
@@ skipping 141 matching lines @@
   if (main_message_loop_)
     main_message_loop_->set_thread_name(kThreadName);
 
   // Register the main thread by instantiating it, but don't call any methods.
   main_thread_.reset(
       new BrowserThreadImpl(BrowserThread::UI, base::MessageLoop::current()));
 }
 
 void BrowserMainLoop::BrowserThreadsStarted() {
   TRACE_EVENT0("startup", "BrowserMainLoop::BrowserThreadsStarted")
+
+#if !defined(OS_IOS)
+  indexed_db_thread_.reset(new base::Thread("IndexedDB"));
+  indexed_db_thread_->Start();
+#endif
+
 #if defined(OS_ANDROID)
   // Up the priority of anything that touches with display tasks
   // (this thread is UI thread, and io_thread_ is for IPCs).
   io_thread_->SetPriority(base::kThreadPriority_Display);
   base::PlatformThread::SetThreadPriority(
       base::PlatformThread::CurrentHandle(),
       base::kThreadPriority_Display);
 #endif
 
 #if !defined(OS_IOS)
@@ skipping 121 matching lines @@
   if (parameters_.ui_task)
     base::MessageLoopForUI::current()->PostTask(FROM_HERE,
                                                 *parameters_.ui_task);
 
   base::RunLoop run_loop;
   run_loop.Run();
 #endif
 }
 
 }  // namespace content