书到用时方恨少，事非经过不知难。这篇文章主要讲述Android NDK pthreads详细使用相关的知识，希望能为你提供帮助。
这个pthread.h文件可以在NDK环境里创建子线程，并对线程能够做出互斥所、等待、销毁等控制。
写这个博客的原因是我要写如何使用FFmpeg播放视频，因为同时需要播放音频和视频所以需要开启线程，并设置生产者和消费者的关系。
好了直接上整体
1.开启和销毁线程
pthread_create函数能够创建线程，第一个参数是线程的引用，第二个是线程的属性，一般为NULL，第三个为线程运行的函数，第四个是给线程运行函数的参数
pthread_create又是开启线程，只要运行了这个函数线程就会运行起来，也就是运行第三个参数所代表的函数

pthread_t pthreads; pthread_create(& pthreads, NULL, threadFunc, (void *) "zzw");

等待线程完成和返回参数，这个如果开启线程只有一个可以不写，但是如果有多个线程这个就必须要写，不写的话只会运行第一个线程

int retvalue; pthread_join(pthreads,(void**)& retvalue); if(retvalue!=0){ __android_log_print(ANDROID_LOG_ERROR,"hello","thread error occurred"); }

我们再来看看线程运行函数，这个他可以获取参数，并且能能够提前结束线程
void threadFunc(void arg){

char* str=(char*)arg; for(int i=0; i< 3; i++){ __android_log_print(ANDROID_LOG_VERBOSE,"hello","i = %d arg = %s",i,str); //线程自杀，需要返回参数 //pthread_exit((void*)2); //线程他杀 //pthread_cancel() } return (void *) 0;

}
完整例子代码
#include < jni.h>
#include < string>
#include < android/log.h>
#define LOGE(FORMAT,...) android_log_print(ANDROID_LOG_ERROR," LC XXX" ,FORMAT,##VA_ARGS__);
extern " C"
JNIEXPORT jstring
JNICALL
java_com_example_zth_ndkthread_MainActivity_stringFromJNI(
JNIEnv env,
jobject / this */) {
std::string hello = " Hello from C++" ;
return env-> NewStringUTF(hello.c_str());
}
void threadFunc(void arg){

char* str=(char*)arg; for(int i=0; i< 3; i++){ __android_log_print(ANDROID_LOG_VERBOSE,"hello","i = %d arg = %s",i,str); //线程自杀，需要返回参数 //pthread_exit((void*)2); //线程他杀 //pthread_cancel() } return (void *) 0;

}
extern " C"
JNIEXPORT void JNICALL
Java_com_example_zth_ndkthread_MainActivity_startNativeThread(JNIEnv* env, jobject thiz,jint count) {

pthread_t pthreads; pthread_create(& pthreads, NULL, threadFunc, (void *) "zzw"); int retvalue; pthread_join(pthreads,(void**)& retvalue); if(retvalue!=0){ __android_log_print(ANDROID_LOG_ERROR,"hello","thread error occurred"); }

}
2.互斥锁
互斥锁指的是它能够锁住一段代码，使得这段代码在解锁之前不能再被执行一次，
初始化

pthread_mutex_t pthread_mutex; if(pthread_mutex_init(& pthread_mutex,NULL)!=0) return;

开启线程时把互斥锁传给线程运行函数

for(int i=0; i< count; i++){ pthread_create(& pthreads[i],NULL,threadFunc,& pthread_mutex); }

我们再来看看线程运行函数
取出互斥锁并上锁

pthread_mutex_t* pthread_mutex=(pthread_mutex_t*)arg; pthread_mutex_lock(pthread_mutex);

然后一段代码

for(int i=0; i< 3; i++){ __android_log_print(ANDROID_LOG_VERBOSE,"hello","i = %d",i); } __android_log_print(ANDROID_LOG_VERBOSE,"hello","————————————");

解锁
pthread_mutex_unlock(pthread_mutex);
最后销毁互斥锁

pthread_mutex_destroy(& pthread_mutex);

运行效果如下
03-02 14:25:58.346 10022-10077/com.example.zth.ndkthread V/hello: i = 0
03-02 14:25:58.346 10022-10077/com.example.zth.ndkthread V/hello: i = 1
03-02 14:25:58.346 10022-10077/com.example.zth.ndkthread V/hello: i = 2
03-02 14:25:58.346 10022-10077/com.example.zth.ndkthread V/hello: ------------------------
03-02 14:25:58.346 10022-10078/com.example.zth.ndkthread V/hello: i = 0
03-02 14:25:58.346 10022-10078/com.example.zth.ndkthread V/hello: i = 1
03-02 14:25:58.346 10022-10078/com.example.zth.ndkthread V/hello: i = 2
03-02 14:25:58.346 10022-10078/com.example.zth.ndkthread V/hello: ------------------------
03-02 14:25:58.347 10022-10079/com.example.zth.ndkthread V/hello: i = 0
03-02 14:25:58.347 10022-10079/com.example.zth.ndkthread V/hello: i = 1
03-02 14:25:58.347 10022-10079/com.example.zth.ndkthread V/hello: i = 2
03-02 14:25:58.347 10022-10079/com.example.zth.ndkthread V/hello: ————————————
如果我们没有加锁呢

pthread_mutex_t* pthread_mutex=(pthread_mutex_t*)arg;

// pthread_mutex_lock(pthread_mutex);
for(int i=0; i< 3; i++){
android_log_print(ANDROID_LOG_VERBOSE," hello" ," i = %d" ,i);
}
android_log_print(ANDROID_LOG_VERBOSE," hello" ," ------------------------" );
// pthread_mutex_unlock(pthread_mutex);
结果如下
03-02 14:36:50.035 13815-13993/com.example.zth.ndkthread V/hello: i = 0
03-02 14:36:50.035 13815-13993/com.example.zth.ndkthread V/hello: i = 1
03-02 14:36:50.035 13815-13993/com.example.zth.ndkthread V/hello: i = 2
03-02 14:36:50.035 13815-13993/com.example.zth.ndkthread V/hello: ------------------------
03-02 14:36:50.035 13815-13994/com.example.zth.ndkthread V/hello: i = 0
03-02 14:36:50.035 13815-13994/com.example.zth.ndkthread V/hello: i = 1
03-02 14:36:50.035 13815-13994/com.example.zth.ndkthread V/hello: i = 2
03-02 14:36:50.035 13815-13995/com.example.zth.ndkthread V/hello: i = 0
03-02 14:36:50.035 13815-13994/com.example.zth.ndkthread V/hello: ------------------------
03-02 14:36:50.035 13815-13995/com.example.zth.ndkthread V/hello: i = 1
03-02 14:36:50.035 13815-13995/com.example.zth.ndkthread V/hello: i = 2
03-02 14:36:50.035 13815-13995/com.example.zth.ndkthread V/hello: ------------------------
所以互斥锁是先让一个线程做完，然后另外一个线程做。
例子代码：
【Android NDK pthreads详细使用】#include < jni.h>
#include < string>
#include < android/log.h>
#include " pthread.h"
#define LOGE(FORMAT,...) android_log_print(ANDROID_LOG_ERROR," LC XXX" ,FORMAT,##VA_ARGS__);
extern " C"
JNIEXPORT jstring
JNICALL
Java_com_example_zth_ndkthread_MainActivity_stringFromJNI(
JNIEnv env,
jobject / this */) {
std::string hello = " Hello from C++" ;
return env-> NewStringUTF(hello.c_str());
}
void threadFunc(void arg){

pthread_mutex_t* pthread_mutex=(pthread_mutex_t*)arg; pthread_mutex_lock(pthread_mutex); for(int i=0; i< 3; i++){ __android_log_print(ANDROID_LOG_VERBOSE,"hello","i = %d",i); } __android_log_print(ANDROID_LOG_VERBOSE,"hello","------------------------"); pthread_mutex_unlock(pthread_mutex); return (void *) 0;

}
extern " C"
JNIEXPORT void JNICALL
Java_com_example_zth_ndkthread_MainActivity_startNativeThread(JNIEnv* env, jobject thiz,jint count) {

pthread_mutex_t pthread_mutex; if(pthread_mutex_init(& pthread_mutex,NULL)!=0) return; pthread_t pthreads[count]; for(int i=0; i< count; i++){ pthread_create(& pthreads[i],NULL,threadFunc,& pthread_mutex); }for(int i=0; i< count; i++){ int retvalue=https://www.songbingjia.com/android/0; pthread_join(pthreads[i],(void**)& retvalue); if(retvalue!=0){ __android_log_print(ANDROID_LOG_ERROR,"hello","thread error occurred"); } }pthread_mutex_destroy(& pthread_mutex);

}
3.条件变量
视频解码的绘制使用的就是生产者—消费者的模式。比如说我们生产者生成的产品，放到一个队列里面，当生产者生产出产品的时候就会发送信号通知消费者去消费
这个条件变量能够唤醒线程运行
初始化
pthread_cond_init(& c,NULL);
开启生成者线程和消费者线程

pthread_create(& thread_producer, NULL, produce, (void *) "producer"); pthread_create(& thread_comsumer, NULL, comsume, (void *) "comsumer");

循环生产产品，然后提醒消费者

for(; ; ){ pthread_mutex_lock(& m); productNum++; __android_log_print(ANDROID_LOG_VERBOSE,"hello","i = %d",productNum); pthread_cond_signal(& c); pthread_mutex_unlock(& m); }

消费者线程如果发现没有产品就等待条件变量提醒，，如果有产品就消费掉

pthread_mutex_lock(& m); while(productNum == 0){ pthread_cond_wait(& c,& m); } productNum--; __android_log_print(ANDROID_LOG_VERBOSE,"hello","i = %d",productNum); pthread_mutex_unlock(& m);

注意生成者与消费者线程运行的全过程都在互斥锁下，都是按顺序一一执行的，这样对于全局变量productNum的计算就不会错误，并且通过一个线程执行pthread_cond_signal来触发另一个线程执行
例子代码
#include < jni.h>
#include < string>
#include < android/log.h>
#include " pthread.h"
#define LOGE(FORMAT,...) android_log_print(ANDROID_LOG_ERROR," LC XXX" ,FORMAT,##VA_ARGS__);
extern " C"
JNIEXPORT jstring
JNICALL
Java_com_example_zth_ndkthread_MainActivity_stringFromJNI(
JNIEnv env,
jobject / this */) {
std::string hello = " Hello from C++" ;
return env-> NewStringUTF(hello.c_str());
}
int productNum = 0;
pthread_mutex_t m;
pthread_cond_t c;
void produce(void arg){
char no = (char)arg;
for(; ; ){
pthread_mutex_lock(& m);
productNum++;
__android_log_print(ANDROID_LOG_VERBOSE," hello" ," i = %d" ,productNum);
pthread_cond_signal(& c);
pthread_mutex_unlock(& m);

}

}
void comsume(void arg){
char no = (char)arg;
for(; ; ){
pthread_mutex_lock(& m);
while(productNum == 0){
pthread_cond_wait(& c,& m);

} productNum--; __android_log_print(ANDROID_LOG_VERBOSE,"hello","i = %d",productNum); pthread_mutex_unlock(& m); }

}
extern " C"
JNIEXPORT void JNICALL
Java_com_example_zth_ndkthread_MainActivity_startNativeThread(JNIEnv* env, jobject thiz,jint count) {

pthread_mutex_init(& m,NULL); pthread_cond_init(& c,NULL); pthread_t thread_producer; pthread_t thread_comsumer; pthread_create(& thread_producer, NULL, produce, (void *) "producer"); pthread_create(& thread_comsumer, NULL, comsume, (void *) "comsumer"); pthread_join(thread_producer,NULL); pthread_join(thread_comsumer,NULL); pthread_mutex_destroy(& m); pthread_cond_destroy(& c);

}
参考文章
https://www.jianshu.com/p/453d12c16885
http://blog.csdn.net/lxmhuendan/article/details/11967593

推荐阅读

• 

  性价比高的男士面膜 男士面膜哪个牌子好
• 

  女性气血不足的6个表现 气血不足的症状有哪些表现女人？
• 

  如何办早教中心？
• 

  洗衣机免拆和拆洗哪种好哪种更适合你,大概率是这几个问题
• 

  电子商务发展现状分析
• 

  苹果6屏幕上的悬浮按钮怎么设置
• 

  睡上下铺对孩子的影响 睡上下铺有风水讲究吗
• 

  yoosee安卓版,如何安装智能家居产品?
• 

  建立空间站有什么用处呢?为什么不多建立几个空间站?
• 

  儿童吃蚝油对身体有害吗
• 

  大学的国际班什么意思可靠吗 大学的国际班的意思
• 

  冰皮月饼放冷冻还是冷藏
• 

  苹果总部
• 

  pcb板是什么材料？PCB板是什么东西
• 

  etc怎么充值缴费 etc怎么充值
• 

  附演出内容 2023淮安元旦文旅惠民演出直播观看入口
• 

  一举两得的举是什么意思 一举两得的举什么意思是什么
• 

  女生与女生聊天技巧
• 

  Presto调优总结
• 

  肺癌|肺癌早期能活多久？医生：看治疗情况

• Android 音视频深入 十八 FFmpeg播放视频，有声音（附源码下载）
• app抓包，根据接口开发web端
• appium desktop连接模拟器
• Android adb你真的会用吗?
• 记一次APP和DB间流量异常问题的排查
• android studio 3.0加载其他人项目时的一些配置问题
• 小学四则运算口算练习app---No.7
• 小学四则运算口算练习app---No.4
• 小学四则运算口算练习app---No.3