Initialize COM STA in the service process.

chrome/service/service_process.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 "chrome/service/service_process.h"
 
 #include <algorithm>
 #include <utility>
+#include <vector>
 
 #include "base/base_switches.h"
 #include "base/callback.h"
 #include "base/command_line.h"
 #include "base/environment.h"
 #include "base/i18n/rtl.h"
 #include "base/location.h"
 #include "base/macros.h"
 #include "base/memory/ptr_util.h"
 #include "base/memory/singleton.h"
 #include "base/path_service.h"
 #include "base/single_thread_task_runner.h"
 #include "base/strings/string16.h"
 #include "base/strings/utf_string_conversions.h"
 #include "base/synchronization/waitable_event.h"
+#include "base/task_scheduler/scheduler_worker_pool_params.h"
 #include "base/task_scheduler/task_scheduler.h"
 #include "base/threading/sequenced_worker_pool.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "base/time/time.h"
 #include "base/values.h"
 #include "build/build_config.h"
 #include "chrome/common/chrome_constants.h"
 #include "chrome/common/chrome_paths.h"
 #include "chrome/common/chrome_switches.h"
 #include "chrome/common/env_vars.h"
@@ skipping 104 matching lines @@
 
 bool ServiceProcess::Initialize(base::MessageLoopForUI* message_loop,
                                 const base::CommandLine& command_line,
                                 ServiceProcessState* state) {
 #if defined(USE_GLIB)
   // g_type_init has been deprecated since version 2.35.
 #if !GLIB_CHECK_VERSION(2, 35, 0)
   // GLib type system initialization is needed for gconf.
   g_type_init();
 #endif
-#endif // defined(OS_LINUX) || defined(OS_OPENBSD)
+#endif  // defined(OS_LINUX) || defined(OS_OPENBSD)
   main_message_loop_ = message_loop;
   service_process_state_.reset(state);
   network_change_notifier_.reset(net::NetworkChangeNotifier::Create());
   base::Thread::Options options;
   options.message_loop_type = base::MessageLoop::TYPE_IO;
   io_thread_.reset(new ServiceIOThread("ServiceProcess_IO"));
   file_thread_.reset(new base::Thread("ServiceProcess_File"));
   if (!io_thread_->StartWithOptions(options) ||
       !file_thread_->StartWithOptions(options)) {
     NOTREACHED();
     Teardown();
     return false;
   }
 
   // Initialize TaskScheduler and redirect SequencedWorkerPool tasks to it.
-  base::TaskScheduler::CreateAndSetSimpleTaskScheduler(
-      "CloudPrintServiceProcess");
+  constexpr int kMaxTaskSchedulerThreads = 3;
+  std::vector<base::SchedulerWorkerPoolParams> worker_pool_params_vector;
+  worker_pool_params_vector.emplace_back(
+      "CloudPrintServiceProcess", base::ThreadPriority::NORMAL,
+      base::SchedulerWorkerPoolParams::StandbyThreadPolicy::LAZY,
+      kMaxTaskSchedulerThreads, base::TimeDelta::FromSeconds(30));

[robliao, 2017/03/24 00:40:17]

Given that you need COM to be initialized, you'll need to specify
SchedulerBackwardCompatibility::INIT_COM_STA.

[Lei Zhang, 2017/03/24 01:15:34]

Doh. That's rather embarassing.

[robliao, 2017/03/24 01:22:20]

Happens to all of us :-)

+  base::TaskScheduler::CreateAndSetDefaultTaskScheduler(
+      worker_pool_params_vector,
+      base::Bind([](const base::TaskTraits&) -> size_t { return 0; }));
   base::SequencedWorkerPool::EnableWithRedirectionToTaskSchedulerForProcess();
 
-  blocking_pool_ = new base::SequencedWorkerPool(
-      3, "ServiceBlocking", base::TaskPriority::USER_VISIBLE);
+  blocking_pool_ =
+      new base::SequencedWorkerPool(kMaxTaskSchedulerThreads, "ServiceBlocking",
+                                    base::TaskPriority::USER_VISIBLE);
 
   // Initialize Mojo early so things can use it.
   mojo::edk::Init();
   mojo_ipc_support_.reset(new mojo::edk::ScopedIPCSupport(
       io_thread_->task_runner(),
       mojo::edk::ScopedIPCSupport::ShutdownPolicy::FAST));
 
   request_context_getter_ = new ServiceURLRequestContextGetter();
 
   base::FilePath user_data_dir;
@@ skipping 244 matching lines @@
     } else {
       Shutdown();
     }
   }
 }
 
 ServiceProcess::~ServiceProcess() {
   Teardown();
   g_service_process = NULL;
 }