NDK你必须学习的技术,pthread线程同步互斥锁的使用

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);
}

互斥锁的使用流程:

  1. 初始化互斥锁变量,通过pthread_mutex_init函数
  2. 在线程执行的代码块中,使用pthread_mutex_lock函数进行加锁,加锁后的线程执行代码块同时就只能一个线程访问执行,也就是上述例子thread_callback函数里的遍历打印的功能。
  3. 互斥代码块执行完后,使用pthread_mutex_unlock进行解锁。
  4. 最后记得在主线程把互斥锁遍历给释放销毁,通过pthread_mutex_destroy函数。

看看没有加互斥锁和加了互斥锁的执行结果:

没有加互斥锁结果

加了互斥锁结果

很明显,没有加互斥锁的程序,线程执行是没有顺序的,完全看线程自己抢占cpu执行资源,而且共享变量i的数据已经错乱。
加了互斥锁后,线程之间执行是有序的,当一个线程正在执行互斥锁代码判断的时候,另外一个线程无法访问,并且共享的数据是相互独立的,不用担心正在使用共享数据的时候,被其它的线程修改了值。


1. NDK你必须学习的技术,pthread线程创建
2. NDK你必须学习的技术,pthread线程同步互斥锁的使用
3. NDK你必须学习的技术,pthread线程简单的生产者消费者模式

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容