Android(安卓)C++ 多线程

版权声明：本文为卫伟学习总结文章，转载请注明出处！
Android是基于Linux内核的，而Linux是遵循POSIX线程标准的，POSIX线程库中有一系列Pthreads API方便我们对Linux线程的操作。所以在Android中使用C/C++线程也就转到了使用POSIX线程库。他们都在头文件"pthread.h"中。
一、创建子线程
1.pthread_t:用来声明一个线程对象如：pthread_t thread;
2.pthread_create:用来创建一个实际的线程如:pthread_create(&pthread,NULL,threadCallBack,NULL);其总共接收4个参数，第一个参数为pthread_t对象，第二个参数为线程的一些属性，一般传NULL。第三个参数为线程执行的函数(void * threadCallBack(void *data)，第四个参数为传递给线程的参数是void *类型的，即可以传任意类型。
3.pthread_exit:用于退出线程如:pthread_exit(&thread)，参数也可以传NULL。注:线程回调函数最后必须调用此方法，不然APP会退出（挂掉）。

pthread_t  thread;void *normalCallBack(void * data) {    LOGI("create normal thread from c++!");    pthread_exit(&thread);}extern  "C"JNIEXPORT void JNICALLJava_com_day1_jado_mymusic_ThreadDemo_normalThread(JNIEnv *env, jobject instance) {    // TODO    pthread_create(&thread, NULL, normalCallBack,NULL);}

二、生成者和消费者模型
1.pthread_mutex_t:用于创建线程锁对象如:pthread_mutex_t mutex;
2.pthread_mutex_init:用于初始化pthread_mutex_t锁对象如:pthread_mutex_init(&mutex，NULL);
3.pthread_mutex_destroy:用于销毁pthread_mutex_t锁对象如:pthread_mutex_destroy(&mutex);
4.pthread_mutex_cond_t:用于创建线程条件对象如:pthread_cond_t cond;
5.pthread_cond_init:用于初始化pthread_cond_t条件对象如:pthread_cond_init(&cond,NULL)；
6.pthread_cond_destroy:用于销毁pthread_cond_t条件对象如:pthread_cond_destroy（&cond）;
7.pthread_mutex_lock:用于上锁mutex,本线程上锁后的其他变量是不能被别的线程操作的如:pthread_mutex_lock(&mutex);
8.pthread_mutex_unlock:用于解锁mutex,解锁后的其他变量可以被其他线程操作如：pthread_mutex_unlock(&mutex);
9.pthread_cond_signal:用于发出条件信号如:pthread_cond_signal(&mutex,&cond);
10.pthread_cond_wait:用于线程阻塞等待，直到pthread_cond_signalfaculty条件信号后才执行退出线程阻塞执行后面的操作。

#include "queue"#include "unistd.h"pthread_t produc;pthread_t custom;pthread_mutex_t mutex;pthread_cond_t cond;std::queue queue;void *producCallback(void *data) {while(1) {    pthread_mutex_lock(&mutex);    queue.push(1);    LOGI("生产者生产一个产品，通知消费者消费， 产品数量为 %d", queue.size());    pthread_cond_signal(&cond);    pthread_mutex_unlock(&mutex);    sleep(5);}pthread_exit(&produc);}void *customCallback(void *data) {while(1) {    pthread_mutex_lock(&mutex);    if(queue.size() > 0) {        queue.pop();        LOGI("消费者消费产品，产品数量还剩余 %d ", queue.size());    } else {        LOGI("没有产品可以消费， 等待中...");        pthread_cond_wait(&cond, &mutex);    }    pthread_mutex_unlock(&mutex);    usleep(500 * 1000);}pthread_exit(&custom);}extern "C"JNIEXPORT void JNICALLJava_com_day1_jado_mymusic_ThreadDemo_mutexThread(JNIEnv *env, jobject instance) {for(int i = 0; i < 10; i++) {    queue.push(i);}pthread_mutex_init(&mutex,NULL);pthread_cond_init(&cond, NULL);pthread_create(&produc, NULL, producCallback, NULL);pthread_create(&custom,NULL, customCallback, NULL);}

更多相关文章

随机推荐