1. NDK你必须学习的技术,pthread线程创建
2. NDK你必须学习的技术,pthread线程同步互斥锁的使用
3. NDK你必须学习的技术,pthread线程简单的生产者消费者模式
我们学习过pthread的线程创建后,再来学习线程同步互斥锁的使用,互斥锁类似于java线程的同步synchronized或者lock、unlock。
// pthread_create_demo02.c
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <pthread.h> // 引入pthread头文件
// 互斥锁变量
pthread_mutex_t mutex;
int i = 0;
// 线程回调执行函数
void* thread_callback(void* arg){
// 加锁
pthread_mutex_lock(&mutex);
char* ch = (char*)arg;
for(; i < 5; i++){
printf("%s thread, i:%d\n", ch, i);
// 为了打印的时候能看出执行效果,在此对当前执行的线程休眠1秒后再执行程序
sleep(1);
}
i = 0;
// 解锁
pthread_mutex_unlock(&mutex);
}
void main(){
// 创建两个线程,用于争夺使用共享功能资格,来达到互斥锁目的
pthread_t tid1, tid2;
// 初始化互斥锁变量
pthread_mutex_init(&mutex, NULL);
// 创建两个线程
pthread_create(&tid1, NULL, thread_callback, "Jerry01");
pthread_create(&tid2, NULL, thread_callback, "Jerry02");
// 等待两个线程执行完成
pthread_join(tid1, NULL);
pthread_join(tid2, NULL);
// 结束销毁互斥锁
pthread_mutex_destroy(&mutex);
}
互斥锁的使用流程:
- 初始化互斥锁变量,通过pthread_mutex_init函数
- 在线程执行的代码块中,使用pthread_mutex_lock函数进行加锁,加锁后的线程执行代码块同时就只能一个线程访问执行,也就是上述例子thread_callback函数里的遍历打印的功能。
- 互斥代码块执行完后,使用pthread_mutex_unlock进行解锁。
- 最后记得在主线程把互斥锁遍历给释放销毁,通过pthread_mutex_destroy函数。
看看没有加互斥锁和加了互斥锁的执行结果:
很明显,没有加互斥锁的程序,线程执行是没有顺序的,完全看线程自己抢占cpu执行资源,而且共享变量i的数据已经错乱。
加了互斥锁后,线程之间执行是有序的,当一个线程正在执行互斥锁代码判断的时候,另外一个线程无法访问,并且共享的数据是相互独立的,不用担心正在使用共享数据的时候,被其它的线程修改了值。
1. NDK你必须学习的技术,pthread线程创建
2. NDK你必须学习的技术,pthread线程同步互斥锁的使用
3. NDK你必须学习的技术,pthread线程简单的生产者消费者模式