Home | History | Annotate | Download | only in android 
      1 // Copyright 2013 The Chromium Authors. All rights reserved.
      2 // Use of this source code is governed by a BSD-style license that can be
      3 // found in the LICENSE file.
      4 
      5 #include "base/android/java_handler_thread.h"
      6 
      7 #include <jni.h>
      8 
      9 #include "base/android/jni_android.h"
     10 #include "base/android/jni_string.h"
     11 #include "base/message_loop/message_loop.h"
     12 #include "base/synchronization/waitable_event.h"
     13 #include "base/threading/thread_restrictions.h"
     14 #include "jni/JavaHandlerThread_jni.h"
     15 
     16 namespace base {
     17 
     18 namespace android {
     19 
     20 JavaHandlerThread::JavaHandlerThread(const char* name) {
     21   JNIEnv* env = base::android::AttachCurrentThread();
     22 
     23   java_thread_.Reset(Java_JavaHandlerThread_create(
     24       env, ConvertUTF8ToJavaString(env, name).obj()));
     25 }
     26 
     27 JavaHandlerThread::~JavaHandlerThread() {
     28 }
     29 
     30 void JavaHandlerThread::Start() {
     31   // Check the thread has not already been started.
     32   DCHECK(!message_loop_);
     33 
     34   JNIEnv* env = base::android::AttachCurrentThread();
     35   base::WaitableEvent initialize_event(
     36       WaitableEvent::ResetPolicy::AUTOMATIC,
     37       WaitableEvent::InitialState::NOT_SIGNALED);
     38   Java_JavaHandlerThread_start(env,
     39                                java_thread_.obj(),
     40                                reinterpret_cast<intptr_t>(this),
     41                                reinterpret_cast<intptr_t>(&initialize_event));
     42   // Wait for thread to be initialized so it is ready to be used when Start
     43   // returns.
     44   base::ThreadRestrictions::ScopedAllowWait wait_allowed;
     45   initialize_event.Wait();
     46 }
     47 
     48 void JavaHandlerThread::Stop() {
     49   JNIEnv* env = base::android::AttachCurrentThread();
     50   base::WaitableEvent shutdown_event(WaitableEvent::ResetPolicy::AUTOMATIC,
     51                                      WaitableEvent::InitialState::NOT_SIGNALED);
     52   Java_JavaHandlerThread_stop(env,
     53                               java_thread_.obj(),
     54                               reinterpret_cast<intptr_t>(this),
     55                               reinterpret_cast<intptr_t>(&shutdown_event));
     56   // Wait for thread to shut down before returning.
     57   base::ThreadRestrictions::ScopedAllowWait wait_allowed;
     58   shutdown_event.Wait();
     59 }
     60 
     61 void JavaHandlerThread::InitializeThread(JNIEnv* env,
     62                                          const JavaParamRef<jobject>& obj,
     63                                          jlong event) {
     64   // TYPE_JAVA to get the Android java style message loop.
     65   message_loop_.reset(new base::MessageLoop(base::MessageLoop::TYPE_JAVA));
     66   static_cast<MessageLoopForUI*>(message_loop_.get())->Start();
     67   reinterpret_cast<base::WaitableEvent*>(event)->Signal();
     68 }
     69 
     70 void JavaHandlerThread::StopThread(JNIEnv* env,
     71                                    const JavaParamRef<jobject>& obj,
     72                                    jlong event) {
     73   static_cast<MessageLoopForUI*>(message_loop_.get())->QuitWhenIdle();
     74   reinterpret_cast<base::WaitableEvent*>(event)->Signal();
     75 }
     76 
     77 // static
     78 bool JavaHandlerThread::RegisterBindings(JNIEnv* env) {
     79   return RegisterNativesImpl(env);
     80 }
     81 
     82 } // namespace android
     83 } // namespace base
     84