Add support for specifying message loop type and thread priority for content mojo services

content/common/service_manager/embedded_service_runner.cc

 // Copyright 2016 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/common/service_manager/embedded_service_runner.h"
 
 #include <map>
 #include <memory>
 #include <utility>
 #include <vector>
@@ skipping 12 matching lines @@
 
 class EmbeddedServiceRunner::InstanceManager
     : public base::RefCountedThreadSafe<InstanceManager> {
  public:
   InstanceManager(const base::StringPiece& name,
                   const ServiceInfo& info,
                   const base::Closure& quit_closure)
       : name_(name.as_string()),
         factory_callback_(info.factory),
         use_own_thread_(!info.task_runner && info.use_own_thread),
+        message_loop_type_(info.message_loop_type),
+        thread_priority_(info.thread_priority),
         quit_closure_(quit_closure),
         quit_task_runner_(base::ThreadTaskRunnerHandle::Get()),
         service_task_runner_(info.task_runner) {
     if (!use_own_thread_ && !service_task_runner_)
       service_task_runner_ = base::ThreadTaskRunnerHandle::Get();
   }
 
   void BindServiceRequest(service_manager::mojom::ServiceRequest request) {
     DCHECK(runner_thread_checker_.CalledOnValidThread());
 
     if (use_own_thread_ && !thread_) {
       // Start a new thread if necessary.
       thread_.reset(new base::Thread(name_));
-      thread_->Start();
+      base::Thread::Options options;
+      options.message_loop_type = message_loop_type_;
+      options.priority = thread_priority_;
+      thread_->StartWithOptions(options);
       service_task_runner_ = thread_->task_runner();
     }
 
     DCHECK(service_task_runner_);
     service_task_runner_->PostTask(
         FROM_HERE,
         base::Bind(&InstanceManager::BindServiceRequestOnServiceThread,
                    this, base::Passed(&request)));
   }
 
@@ skipping 69 matching lines @@
     if (thread_) {
       thread_.reset();
       service_task_runner_ = nullptr;
     }
     quit_closure_.Run();
   }
 
   const std::string name_;
   const ServiceInfo::ServiceFactory factory_callback_;
   const bool use_own_thread_;
+  base::MessageLoop::Type message_loop_type_;
+  base::ThreadPriority thread_priority_;
   const base::Closure quit_closure_;
   const scoped_refptr<base::SingleThreadTaskRunner> quit_task_runner_;
 
   // Thread checker used to ensure certain operations happen only on the
   // runner's (i.e. our owner's) thread.
   base::ThreadChecker runner_thread_checker_;
 
   // These fields must only be accessed from the runner's thread.
   std::unique_ptr<base::Thread> thread_;
   scoped_refptr<base::SingleThreadTaskRunner> service_task_runner_;
@@ skipping 40 matching lines @@
     const base::Closure& quit_closure) {
   quit_closure_ = quit_closure;
 }
 
 void EmbeddedServiceRunner::OnQuit() {
   if (!quit_closure_.is_null())
     quit_closure_.Run();
 }
 
 }  // namespace content