AndroidNDK多线程初步学习

package com.ndk.cjava.exchange;import java.io.Serializable;import android.util.Log;public class UserEntity implements Serializable {private static final long serialVersionUID &＃61; -8623782232814941002L;private static final String TAG_NAME &＃61; "UserEntity";private String name; private String id;public native UserEntity copyUserEntity();public native static UserEntity newUserEntity(String id,String name);public native void update(String id,String name);public void setName(String name){this.name &＃61; name;}public String getName(){return name;}public static String tag(){return UserEntity.class.getName();}public String getId() {return id;}public void setId(String id) {this.id &＃61; id;}&＃64;Overridepublic String toString() {return "UserEntity [name&＃61;" &＃43; name &＃43; ", id&＃61;" &＃43; id &＃43; "]";}private void throwNewException(){throw new NullPointerException("Null Pointer");}//对象的引用public native void referenceUnit();//本地方法public native void mainThread();public native void setJNIEnv(); //由JNI中的线程回调private static void fromJNI(int i){Log.v("Java------>", ""&＃43;i);}static{System.loadLibrary("NDK_Exchange");}
}

-----实现类-------

#include
#include
#include
#include
#include #define LOGI(...) ((void)__android_log_print(ANDROID_LOG_INFO, "native-activity", __VA_ARGS__))
#define LOGW(...) ((void)__android_log_print(ANDROID_LOG_WARN, "native-activity", __VA_ARGS__))
#define LOGE(...) ((void)__android_log_print(ANDROID_LOG_ERROR, "native-activity", __VA_ARGS__))//全局引用对象
jclass globalJclazz &＃61; NULL;
jclass weakclass &＃61; NULL;//线程数
#define NUMTHREADS 5//全局变量
JavaVM *g_jvm &＃61; NULL;
jobject g_obj &＃61; NULL;/** Class:     com_ndk_cjava_exchange_UserEntity* Method:    copyUserEntity* Signature: ()Lcom/ndk/cjava/exchange/UserEntity;*/
JNIEXPORT jobject JNICALL Java_com_ndk_cjava_exchange_UserEntity_copyUserEntity(JNIEnv *env, jobject thiz)
{jclass jclazz &＃61; env->GetObjectClass(thiz);jmethodID jConstructor&＃61; env->GetMethodID(jclazz,"","()V");jobject newInstance &＃61; env->NewObject(jclazz,jConstructor);jfieldID nameField &＃61;  env->GetFieldID(jclazz,"name","Ljava/lang/String;");jfieldID idField &＃61; env->GetFieldID(jclazz,"id","Ljava/lang/String;");env->SetObjectField(newInstance,nameField,env->GetObjectField(thiz,nameField));env->SetObjectField(newInstance,idField,env->GetObjectField(thiz,idField));return newInstance;
}
/** Class:     com_ndk_cjava_exchange_UserEntity* Method:    newUserEntity* Signature: (Ljava/lang/String;Ljava/lang/String;)Lcom/ndk/cjava/exchange/UserEntity;*/
JNIEXPORT jobject JNICALL Java_com_ndk_cjava_exchange_UserEntity_newUserEntity(JNIEnv * env, jclass clazz, jstring id, jstring name)
{jmethodID jConstructor&＃61; env->GetMethodID(clazz,"","()V");jobject newInstance &＃61; env->NewObject(clazz,jConstructor);jfieldID nameField &＃61;  env->GetFieldID(clazz,"name","Ljava/lang/String;");jfieldID idField &＃61; env->GetFieldID(clazz,"id","Ljava/lang/String;");env->SetObjectField(newInstance,nameField,name);env->SetObjectField(newInstance,idField,id);return newInstance;
}/** Class:     com_ndk_cjava_exchange_UserEntity* Method:    update* Signature: (Ljava/lang/String;Ljava/lang/String;)V*/
JNIEXPORT void JNICALL Java_com_ndk_cjava_exchange_UserEntity_update(JNIEnv * env, jobject thiz, jstring id, jstring name)
{jclass jclz &＃61; env->GetObjectClass(thiz);jmethodID  setNameMethod  &＃61;  env->GetMethodID(jclz,"setName","(Ljava/lang/String;)V");jmethodID  setIdMethod  &＃61;  env->GetMethodID(jclz,"setId","(Ljava/lang/String;)V");env->CallVoidMethod(thiz,setNameMethod,name);env->CallVoidMethod(thiz,setIdMethod,id);jmethodID getNameMethod &＃61;   env->GetMethodID(jclz,"getName","()Ljava/lang/String;");jmethodID getIdMethod  &＃61;   env->GetMethodID(jclz,"getId","()Ljava/lang/String;");jstring mName &＃61; (jstring)(env->CallObjectMethod(thiz,getNameMethod));jstring mId &＃61; (jstring)(env->CallObjectMethod(thiz,getIdMethod));jmethodID sTagMethod &＃61; env->GetStaticMethodID(jclz,"tag","()Ljava/lang/String;");jstring jtag &＃61; (jstring)(env->CallStaticObjectMethod(jclz,sTagMethod));jboolean isCopy;const char * chName &＃61; env->GetStringUTFChars(mName,&isCopy);const char * chId &＃61; env->GetStringUTFChars(mId,&isCopy);const char * chTag &＃61; env->GetStringUTFChars(jtag,&isCopy);jfieldID TagNamefiledId &＃61; env->GetStaticFieldID(jclz,"TAG_NAME","Ljava/lang/String;");jstring jtagName &＃61; (jstring)(env->GetStaticObjectField(jclz,TagNamefiledId));const char * chTagName &＃61;  env->GetStringUTFChars(jtagName,&isCopy);__android_log_print(ANDROID_LOG_ERROR,chTag,"TAG_NAME&＃61;%s,name&＃61;%s,id&＃61;%s",chTagName,chName,chId);//异常处理---java代码抛出的异常导致jvm shut down/**jmethodID  throwNewExceptionMethodID &＃61; env->GetMethodID(jclz,"throwNewException","()V");env->CallCharMethod(thiz,throwNewExceptionMethodID);jthrowable tr &＃61; env->ExceptionOccurred();if(tr!&＃61;NULL){env->ExceptionClear();}**///主动抛出异常---c抛出的异常程序不会停止env->ThrowNew(jclz,"主动抛出的异常");jthrowable tr &＃61; env->ExceptionOccurred();if(tr!&＃61;NULL){env->ExceptionClear();env->DeleteLocalRef(jclz);}}/** Class:     com_ndk_cjava_exchange_UserEntity* Method:    referenceUnit* Signature: ()V*/
JNIEXPORT void JNICALL Java_com_ndk_cjava_exchange_UserEntity_referenceUnit(JNIEnv * env, jobject thiz)
{/*if(globalJclazz&＃61;&＃61;NULL){__android_log_print(ANDROID_LOG_INFO,"REF","--1-->");globalJclazz &＃61; (jclass)(env->NewGlobalRef(env->GetObjectClass(thiz)));}else{__android_log_print(ANDROID_LOG_INFO,"REF","--2-->");env->DeleteGlobalRef(globalJclazz);globalJclazz &＃61; NULL;}*///if(weakclass&＃61;&＃61;NULL || (env->IsSameObject(weakclass,NULL))&＃61;&＃61;JNI_TRUE){jclass jclzz  &＃61; env->GetObjectClass(thiz);weakclass &＃61; (jclass)(env->NewWeakGlobalRef(jclzz));}else{env->DeleteWeakGlobalRef(weakclass);weakclass &＃61; NULL;}
}/****---------------------------------------多线程---------------------------------------***/
void *thread_fun(void* arg)
{JNIEnv * env &＃61; NULL;jclass cls &＃61; NULL;jmethodID mid &＃61; NULL;//Attach主线程if(g_jvm->AttachCurrentThread( &env, NULL) !&＃61; JNI_OK){LOGE("%s: AttachCurrentThread() failed", __FUNCTION__);return NULL;}//找到对应的类cls &＃61; env->GetObjectClass(g_obj);if(cls &＃61;&＃61; NULL){LOGE("FindClass() Error.....");goto error;}//再获得类中的方法mid &＃61; env->GetStaticMethodID( cls, "fromJNI", "(I)V");if (mid &＃61;&＃61; NULL){LOGE("GetMethodID() Error.....");goto error;}//最后调用java中的静态方法env->CallStaticVoidMethod( cls, mid ,(int)arg);
error://Detach主线程if(g_jvm->DetachCurrentThread() !&＃61; JNI_OK){LOGE("%s: DetachCurrentThread() failed", __FUNCTION__);}pthread_exit(0);
}JNIEXPORT void JNICALL Java_com_ndk_cjava_exchange_UserEntity_mainThread(JNIEnv * env, jobject thiz)
{int i;pthread_t pt[NUMTHREADS];for (i &＃61; 0; i < NUMTHREADS; i&＃43;&＃43;){   //创建子线程pthread_create(&pt[i], NULL, &thread_fun, (void *)i);}
}JNIEXPORT void JNICALL Java_com_ndk_cjava_exchange_UserEntity_setJNIEnv(JNIEnv * env, jobject thiz)
{//保存全局JVM以便在子线程中使用env->GetJavaVM(&g_jvm);//不能直接赋值(g_obj &＃61; obj)g_obj &＃61; env->NewGlobalRef(thiz);//变为全局变量
}//当动态库被加载时这个函数被系统调用JNIEXPORT jint JNICALL JNI_OnLoad(JavaVM *vm, void *reserved){LOGE("JNI_OnLoad");JNIEnv* env &＃61; NULL;jint result &＃61; -1;//获取JNI版本if (vm->GetEnv((void**)&env, JNI_VERSION_1_4) !&＃61; JNI_OK){LOGE("GetEnv failed!");return result;}return JNI_VERSION_1_4;}//当动态库被卸载时这个函数被系统调用JNIEXPORT void JNICALL JNI_OnUnload(JavaVM* vm, void* reserved){LOGE("JNI_OnUnload");}