android: Java-based launcher thread

base/android/java_handler_thread.cc

 // Copyright 2013 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 "base/android/java_handler_thread.h"
 
 #include <jni.h>
 
 #include "base/android/jni_android.h"
 #include "base/android/jni_string.h"
 #include "base/message_loop/message_loop.h"
 #include "base/synchronization/waitable_event.h"
 #include "base/threading/thread_restrictions.h"
 #include "jni/JavaHandlerThread_jni.h"
 
+using base::android::AttachCurrentThread;
+
 namespace base {
 
 namespace android {
 
-JavaHandlerThread::JavaHandlerThread(const char* name) {
-  JNIEnv* env = base::android::AttachCurrentThread();
+JavaHandlerThread::JavaHandlerThread(const char* name)
+    : JavaHandlerThread(Java_JavaHandlerThread_create(
+          AttachCurrentThread(),
+          ConvertUTF8ToJavaString(AttachCurrentThread(), name))) {}
 
-  java_thread_.Reset(
-      Java_JavaHandlerThread_create(env, ConvertUTF8ToJavaString(env, name)));
-}
+JavaHandlerThread::JavaHandlerThread(
+    const base::android::ScopedJavaLocalRef<jobject>& obj)
+    : java_thread_(obj) {}
 
 JavaHandlerThread::~JavaHandlerThread() {
 }
 
 void JavaHandlerThread::Start() {
   // Check the thread has not already been started.
   DCHECK(!message_loop_);
 
   JNIEnv* env = base::android::AttachCurrentThread();
   base::WaitableEvent initialize_event(
       WaitableEvent::ResetPolicy::AUTOMATIC,
       WaitableEvent::InitialState::NOT_SIGNALED);
-  Java_JavaHandlerThread_start(env, java_thread_,
-                               reinterpret_cast<intptr_t>(this),
-                               reinterpret_cast<intptr_t>(&initialize_event));
+  Java_JavaHandlerThread_startAndInitialize(
+      env, java_thread_, reinterpret_cast<intptr_t>(this),
+      reinterpret_cast<intptr_t>(&initialize_event));
   // Wait for thread to be initialized so it is ready to be used when Start
   // returns.
   base::ThreadRestrictions::ScopedAllowWait wait_allowed;
   initialize_event.Wait();
 }
 
 void JavaHandlerThread::Stop() {
   JNIEnv* env = base::android::AttachCurrentThread();
   base::WaitableEvent shutdown_event(WaitableEvent::ResetPolicy::AUTOMATIC,
                                      WaitableEvent::InitialState::NOT_SIGNALED);
@@ skipping 29 matching lines @@
   static_cast<MessageLoopForUI*>(message_loop_.get())->QuitWhenIdle();
 }
 
 // static
 bool JavaHandlerThread::RegisterBindings(JNIEnv* env) {
   return RegisterNativesImpl(env);
 }
 
 } // namespace android
 } // namespace base