Chromium Code Reviews| Index: base/android/java_handler_thread.cc |
| diff --git a/base/android/java_handler_thread.cc b/base/android/java_handler_thread.cc |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..61e9b820e7d6d5af3204609e1a5de95291f7f444 |
| --- /dev/null |
| +++ b/base/android/java_handler_thread.cc |
| @@ -0,0 +1,59 @@ |
| +// Copyright (c) 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_thread.h" |
| + |
| +#include <jni.h> |
| + |
| +#include "base/android/jni_android.h" |
| +#include "base/android/jni_string.h" |
| +#include "base/message_loop.h" |
| +#include "base/synchronization/waitable_event.h" |
| +#include "jni/JavaThread_jni.h" |
| + |
| +namespace base { |
| + |
| +namespace android { |
| + |
| +JavaHandlerThread::JavaHandlerThread(const char* name) |
| + : started_(false) { |
| + JNIEnv* env = base::android::AttachCurrentThread(); |
| + |
| + java_thread_.Reset(Java_JavaHandlerThread_create( |
| + env, ConvertUTF8ToJavaString(env, name).Release())); |
| +} |
| + |
| +void JavaHandlerThread::Start() { |
| + // Check the thread has not already been started. |
| + DCHECK(!started_); |
|
joth
2013/07/17 21:16:19
nit: the comment is kind of spurious :)
nit: we'd
|
| + |
| + JNIEnv* env = base::android::AttachCurrentThread(); |
| + base::WaitableEvent initialize_event(false, false); |
| + Java_JavaHandlerThread_start(env, |
| + java_thread_.obj(), |
| + reinterpret_cast<jint>(this), |
| + reinterpret_cast<jint>(&initialize_event)); |
| + // Wait for thread to be initialized so it is ready to be used when Start |
| + // returns. |
| + initialize_event.Wait(); |
| + started_ = true; |
| +} |
| + |
| +void JavaHandlerThread::Stop() { |
| +} |
| + |
| +void JavaHandlerThread::InitializeThread(JNIEnv* env, jobject obj, jint event) { |
| + // TYPE_UI to get the Android java style message loop. |
| + message_loop_.reset(new base::MessageLoop(base::MessageLoop::TYPE_UI)); |
| + MessageLoopForUI::current()->Start(); |
| + reinterpret_cast<base::WaitableEvent*>(event)->Signal(); |
| +} |
| + |
| +// static |
| +bool JavaHandlerThread::RegisterBindings(JNIEnv* env) { |
| + return RegisterNativesImpl(env); |
| +} |
| + |
| +} // namespace android |
| +} // namespace base |