Android C++系列:JNI中的线程操作

简介: 第四个参数为线程启动程序的参数,也就是函数的参数,如果不需要传递参数,它可以为 NULL 。 pthread_create 函数如果执行成功了则返回 0 ,如果返回其他错误代码。

image.png


Java中创建线程三种方式:


  1. 继承Thread类创建线程类;
  2. 通过Runnable接口创建线程类;
  3. 通过Callable和Future创建线程。


Native 中支持的线程标准是 POSIX 线程,它定义了一套创建和操作线程的 API 。


我们可以在 Native 代码中使用 POSIX 线程,就相当于使用一个库一样,首先需要包含这个库的头文件:


#include <pthread.h>              


这个头文件中定义了很多和线程相关的函数,这里就暂时使用到了其中创建线程部分内容。


创建线程


POSIX 创建线程的函数如下:


int pthread_create(
   pthread_t* __pthread_ptr, 
   pthread_attr_t const* __attr, 
   void* (*__start_routine)(void*), 
   void* arg);


它的参数对应如下:


  • __pthread_ptr 为指向 pthread_t 类型变量的指针,用它代表返回线程的句柄。
  • __attr 为指向 pthread_attr_t 结构的指针,可以通过该结构来指定新线程的一些属性,比如栈大小、调度优先级等,具体看 pthread_attr_t 结构的内容。如果没有特殊要求,可使用默认值,把该变量取值为 NULL 。 第三个参数为该线程启动程序的函数指针,也就是线程启动时要执行的那个方法,类似于 Java Runnable 中的 run 方法,它的函数签名格式如下:


void* start_routine(void* args)              


启动程序将线程参数看成 void 指针,返回 void 指针类型结果。


  • 第四个参数为线程启动程序的参数,也就是函数的参数,如果不需要传递参数,它可以为 NULL 。 pthread_create 函数如果执行成功了则返回 0 ,如果返回其他错误代码。


接下来,我们使用pthread_create 方法来创建线程。


第一步,我们创建线程启动时运行的入口函数:


void *printThreadHello(void *);
 void *printThreadHello(void *) {
 LOGD("hello thread");
 // 切记要有返回值
 return NULL;
 }            


要注意线程启动函数是要有返回值的,没有返回值就直接崩溃了


一旦 pthread_create 调用了,printThreadHello就会立即执行。


接下来我们使用JNI封装创建线程:


JNIEXPORT void JNICALL
 Java_com_qingkouwei_Demo_createNativeThread(JNIEnv *, jobject) {
     pthread_t handles; // 线程句柄
     int result = pthread_create(&handles, NULL, printThreadHello, NULL);
     if (result != 0) {
         LOGD("create thread failed");
     } else {
         LOGD("create thread success");
     }
 }


由于我们没有给该线程设置属性,并且线程运行函数也不需要参数,就都直接设置为了 NULL,那么上面那段程序就可以执行了,并且 printThreadHello 函数是运行在新的线程中的,运行完成后线程就退出了。


将线程附着在 Java 虚拟机上


在上面的线程启动函数中,只是简单的执行了打印 log 的操作,如果想要执行和 Java 相关的操作,比如从 JNI 调用 Java 的函数等等,那就需要用到 Java 虚拟机环境了,也就是用到 JNIEnv 指针,毕竟所有的调用函数都是以它开头的。


pthread_create 创建的线程是一个 C 中的线程,虚拟机并不能识别它们,为了和 Java 空间交互,需要先把 POSIX 线程附着到 Java 虚拟机上,然后就可以获得当前线程的 JNIEnv 指针,因为 JNIEnv 指针只是在当前线程中有效。


通过 AttachCurrentThread 方法可以将当前线程附着到 Java 虚拟机上,并且可以获得 JNIEnv 指针。


AttachCurrentThread 方法是由 JavaVM 指针调用的,它代表的是 Java 虚拟机接口指针,可以在 JNI_OnLoad 加载时来获得,通过全局变量保存起来


static JavaVM *gVm = NULL;
 JNIEXPORT int JNICALL JNI_OnLoad(JavaVM *vm, void *reserved) {
     JNIEnv *env;
     if (vm->GetEnv((void **) &env, JNI_VERSION_1_6) != JNI_OK) {
         return JNI_ERR;
     }
     gVm = vm;
     return JNI_VERSION_1_6;
 }


当通过 AttachCurrentThread 方法将线程附着当 Java 虚拟机上后,还需要将该线程从 Java 虚拟机上分离,通过 DetachCurrentThread 方法,这两个方法是要同时使用的,否则会出现问题 。


具体使用如下:


1.首先在 Java 中定义在 C++ 线程中回调的方法,主要就是打印线程名字:


private void printThreadName() {
    Log.d(”DEMO","print thread name current thread name is " + Thread.currentThread().getName());
         Thread.sleep(5000);
 }


2.然后定义 Native 线程中运行的方法:


void *run(void *);
void *run(void *args) {
     JNIEnv *env = NULL;
     // 将当前线程添加到 Java 虚拟机上
     // 假设有参数传递
     ThreadRunArgs *threadRunArgs = (ThreadRunArgs *) args;
     if (gVm->AttachCurrentThread(&env, NULL) == 0) {
     // 回调 Java 的方法,打印当前线程 id ,发现不是主线程就对了
         env->CallVoidMethod(gObj, printThreadName);
         // 从 Java 虚拟机上分离当前线程
         gVm->DetachCurrentThread();  
     }
     return (void *) threadRunArgs->result;
 }


3.最后创建线程并运行方法:


// 创建传递的参数
    ThreadRunArgs *threadRunArgs = new ThreadRunArgs();
    threadRunArgs->id = i;
    threadRunArgs->result = i * i;
    // 运行线程
    int result = pthread_create(&handles, NULL, run, (void *) threadRunArgs);


通过这样的调用,就可以在 Native 线程中调用 Java 相关的函数了。


等待线程返回结果


前面提到在线程运行函数中必须要有返回值,最开始只是返回了一个空指针 NULL ,并且在某个方法里面开启了新线程,新线程运行后,该方法也就立即返回退出,执行完了。


现在,还可以在该方法里等待线程执行完毕后,拿到线程执行完的结果之后再退出。


和Java的join方法类似,C中可以通过 pthread_join 方法可以等待线程终止。


int pthread_join(pthread_t __pthread, void** __return_value_ptr);


其中:


  • __pthread 代表创建线程的句柄
  • __return_value_ptr 代表线程运行函数返回的结果 使用如下:


for (int i = 0; i < num; ++i) {
       pthread_t pthread;
       // 创建线程,
       int result = pthread_create(&handles[i], NULL, run, (void *) threadRunArgs);
       }
   }
   for (int i = 0; i < num; ++i) {
       void *result = NULL; // 线程执行返回结果
       // 等待线程执行结束
       if (pthread_join(handles[i], &result) != 0) {
           throwByName(env, runtimeException, "Unable to join thread");
       } else {
           LOGD("return value is %d",result);
       }
   }


如果 pthread_join 返回为 0 代表执行成功,非 0 则执行失败。


总结


本文介绍了通过C语言创建线程的方法和C层等待线程返回的方法,以及JNI提供的AttachCurrentThread 和 DetachCurrentThread方法,通过该方法将C线程附着到Java虚拟机,同时我们还介绍了JNI_OnLoad方法和JavaVM结构。

目录
相关文章
|
17天前
|
缓存 安全 C++
C++无锁队列:解锁多线程编程新境界
【10月更文挑战第27天】
30 7
|
17天前
|
消息中间件 存储 安全
|
1月前
|
存储 消息中间件 资源调度
C++ 多线程之初识多线程
这篇文章介绍了C++多线程的基本概念,包括进程和线程的定义、并发的实现方式,以及如何在C++中创建和管理线程,包括使用`std::thread`库、线程的join和detach方法,并通过示例代码展示了如何创建和使用多线程。
43 1
C++ 多线程之初识多线程
|
23天前
|
存储 并行计算 安全
C++多线程应用
【10月更文挑战第29天】C++ 中的多线程应用广泛,常见场景包括并行计算、网络编程中的并发服务器和图形用户界面(GUI)应用。通过多线程可以显著提升计算速度和响应能力。示例代码展示了如何使用 `pthread` 库创建和管理线程。注意事项包括数据同步与互斥、线程间通信和线程安全的类设计,以确保程序的正确性和稳定性。
|
1月前
|
存储 前端开发 C++
C++ 多线程之带返回值的线程处理函数
这篇文章介绍了在C++中使用`async`函数、`packaged_task`和`promise`三种方法来创建带返回值的线程处理函数。
45 6
|
1月前
|
缓存 负载均衡 Java
c++写高性能的任务流线程池(万字详解!)
本文介绍了一种高性能的任务流线程池设计,涵盖多种优化机制。首先介绍了Work Steal机制,通过任务偷窃提高资源利用率。接着讨论了优先级任务,使不同优先级的任务得到合理调度。然后提出了缓存机制,通过环形缓存队列提升程序负载能力。Local Thread机制则通过预先创建线程减少创建和销毁线程的开销。Lock Free机制进一步减少了锁的竞争。容量动态调整机制根据任务负载动态调整线程数量。批量处理机制提高了任务处理效率。此外,还介绍了负载均衡、避免等待、预测优化、减少复制等策略。最后,任务组的设计便于管理和复用多任务。整体设计旨在提升线程池的性能和稳定性。
78 5
|
1月前
|
C++
C++ 多线程之线程管理函数
这篇文章介绍了C++中多线程编程的几个关键函数,包括获取线程ID的`get_id()`,延时函数`sleep_for()`,线程让步函数`yield()`,以及阻塞线程直到指定时间的`sleep_until()`。
23 0
C++ 多线程之线程管理函数
|
1月前
|
资源调度 Linux 调度
Linux C/C++之线程基础
这篇文章详细介绍了Linux下C/C++线程的基本概念、创建和管理线程的方法,以及线程同步的各种机制,并通过实例代码展示了线程同步技术的应用。
29 0
Linux C/C++之线程基础
|
2月前
|
Java Android开发 C++
🚀Android NDK开发实战!Java与C++混合编程,打造极致性能体验!📊
在Android应用开发中,追求卓越性能是不变的主题。本文介绍如何利用Android NDK(Native Development Kit)结合Java与C++进行混合编程,提升应用性能。从环境搭建到JNI接口设计,再到实战示例,全面展示NDK的优势与应用技巧,助你打造高性能应用。通过具体案例,如计算斐波那契数列,详细讲解Java与C++的协作流程,帮助开发者掌握NDK开发精髓,实现高效计算与硬件交互。
133 1
|
3月前
|
Java 调度
基于C++11的线程池
基于C++11的线程池