线程间通信方式（互斥（互斥锁）与同步（无名信号量、条件变量））

2024-06-24 05:12
文章标签 互斥 线程 条件 间通信 信号量 方式 变量 同步 无名

本文主要是介绍线程间通信方式（互斥（互斥锁）与同步（无名信号量、条件变量）），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1通信机制：互斥与同步

线程的互斥通过线程的互斥锁完成；

线程的同步通过无名信号量或者条件变量完成。

2  互斥

2.1 何为互斥？

        互斥是在多个线程在访问同一个全局变量的时候，先让这个线程争抢锁的资源，那个线程争抢到资源，它可以访问这个变量，没有争抢到资源的线程不能够访问这个变量。那这种只有一个线程能够访问到这个变量的现象称之为线程间互斥。

2.2互斥锁API

1.定义互斥锁pthread_mutex_t mutex;
2.初始化线程互斥锁pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;//静态初始化int pthread_mutex_init(pthread_mutex_t * mutex,const pthread_mutexattr_t * attr);//动态初始化功能：初始化互斥锁参数：@mutex:被初始化的锁@attr:锁的属性，一般填写为NULL(默认属性)返回值：成功返回0，失败返回错误码
3.上锁int pthread_mutex_trylock(pthread_mutex_t *mutex);//尝试获取锁，如果锁资源存在那就占用锁，如果锁资源不可利用，立即返回。int pthread_mutex_lock(pthread_mutex_t *mutex);功能：上锁（如果线程获取不到锁的资源，线程阻塞，直到其他的线程将锁释放）参数：@mutex:执行锁的指针返回值：成功返回0，失败返回错误码
4.解锁int pthread_mutex_unlock(pthread_mutex_t *mutex);功能：解锁参数：@mutex:执行锁的指针返回值：成功返回0，失败返回错误码 
5.销毁锁int pthread_mutex_destroy(pthread_mutex_t *mutex);功能：销毁互斥锁参数：@mutex:执行锁的指针返回值：成功返回0，失败返回错误码

实例

#include <head.h>
volatile int money = 1000;
pthread_mutex_t lock; // 定义线程互斥锁
void *thread1(void *arg)
{while (1){pthread_mutex_lock(&lock); // 上锁money -= 50;if (money >= 0){printf("张三取走了50块钱,余额 = %d\n", money);}else{money += 50;printf("张三取钱失败，余额不足...\n");pthread_mutex_unlock(&lock); // 解锁pthread_exit(NULL);}// sleep(1);pthread_mutex_unlock(&lock); // 解锁}
}
void *thread2(void *arg)
{while (1){pthread_mutex_lock(&lock); // 上锁money -= 100;if (money >= 0){printf("李四取走了100块钱,余额 = %d\n", money);}else{money += 100;printf("李四取钱失败，余额不足...\n");pthread_mutex_unlock(&lock); // 解锁pthread_exit(NULL);}// sleep(1);pthread_mutex_unlock(&lock); // 解锁}
}
int main(int argc, const char *argv[])
{pthread_t tid1, tid2; // typedef unsigned long int pthread_t;if ((errno = pthread_mutex_init(&lock, NULL)) != 0){ // 线程互斥锁初始化perror("pthread_mutex_init error");exit(-1);}if ((errno = pthread_create(&tid1, NULL, thread1, NULL)) != 0){perror("pthread_create error");exit(-1);}if ((errno = pthread_create(&tid2, NULL, thread2, NULL)) != 0){perror("pthread_create error");exit(-1);}pthread_join(tid1, NULL);pthread_join(tid2, NULL);pthread_mutex_destroy(&lock);return 0;
}

 运行结果

注：使用锁不当可能会产生死锁，死锁规避方法

1.指定线程获取锁的状态

2.尽量避免锁的嵌套使用

3.给线程上锁指定超时时间

4.在全局位置指定锁是否被使用的状态，如果被使用，就不在获取锁（使用volatile int flag=0或1）

        3.同步

3.1 何为同步

线程同步机制是指线程的顺序执行，在线程执行前已经编排好了线程的执行顺序。就不会出现同一时间有多个现在在争抢临界资源了。线程的同步机制一般使用在生成者和消费者模型上(本身也是强调顺序)。

3.2  无名信号量API

注：无名信号量适合线程数比较少的情况的线程同步

#include <semaphore.h>
1.定义无名信号量sem_t sem;
2.初始化无名信号量int sem_init(sem_t *sem, int pshared, unsigned int value);功能：初始化无名信号量参数：@sem:指向无名信号量的指针@pshared:0 线程的同步1 进程的同步（亲缘关系进程）@value:信号的初值  1 0返回值：成功返回0，失败返回-1置位错误码
3.获取信号量（P操作）int sem_wait(sem_t *sem);功能：申请资源（让信号量的值减去1，然后和0比较如果结果为0，表示获取锁成功了）    如果在调用sem_wait的时候获取不到资源，sem_wait会阻塞参数：@sem:指向无名信号量的指针返回值：成功返回0，失败返回-1置位错误码
4.释放信号量（V操作）int sem_post(sem_t *sem);功能：释放资源参数：@sem:指向无名信号量的指针返回值：成功返回0，失败返回-1置位错误码
5.销毁无名信号量int sem_destroy(sem_t *sem);功能：销毁无名信号量参数：@sem:指向无名信号量的指针返回值：成功返回0，失败返回-1置位错误码

实例

要求：有三个线程A,B,C它们分别打印B、G、M三个字符,请使用无名信号量让这三个线程依次打印        BGM

            BGM

            BGM....

03_pthread_wumingxinhaoliang_lizi.c

#include <head.h>
sem_t sem1, sem2, sem3; // 定义无名信号量
void *thread1(void *arg)
{while (1){sem_wait(&sem1);printf("E");sem_post(&sem2);}
}
void *thread2(void *arg)
{while (1){sem_wait(&sem2);printf("G");sem_post(&sem3);}
}
void *thread3(void *arg)
{while (1){sem_wait(&sem3);printf("M\n");sleep(1);sem_post(&sem1);}
}
int main(int argc, const char *argv[])
{pthread_t tid1, tid2, tid3;sem_init(&sem1, 0, 1); // 无名信号量初始化sem_init(&sem2, 0, 0);sem_init(&sem3, 0, 0);if ((errno = pthread_create(&tid1, NULL, thread1, NULL)) != 0){perror("pthread create1 error");exit(-1);}if ((errno = pthread_create(&tid2, NULL, thread2,NULL)) != 0){perror("pthread create2 error");exit(-1);}if ((errno = pthread_create(&tid3, NULL, thread3, NULL)) != 0){perror("pthread create3 error");exit(-1);}pthread_join(tid1, NULL);pthread_join(tid2, NULL);pthread_join(tid3, NULL);sem_destroy(&sem1); // 销毁无名信号量sem_destroy(&sem2);sem_destroy(&sem3);return 0;
}

执行gcc 03_pthread_wumingxinhaoliang_lizi.c -lpthread 编译

运行结果

3.3 条件变量API

        条件变量和无名信号量都是用于线程同步，用哪一个？

        无名信号量适合线程数比较少的情况的线程同步，而条件变量适合大量线程的同步工作。

1.定义条件变量pthread_cond_t cond;2.初始化条件变量pthread_cond_t cond = PTHREAD_COND_INITIALIZER;//静态初始化 int pthread_cond_init(pthread_cond_t * cond,const pthread_condattr_t * attr);功能：动态初始化一个条件变量参数：@cond：条件变量的指针@attr:NULL使用默认属性返回值：成功返回0，失败返回非03.阻塞等待条件变量int pthread_cond_wait(pthread_cond_t * cond,pthread_mutex_t * mutex);功能：阻塞等待条件变量，在条件变量中维护了一个队列，这里的互斥锁就是为了解决在往队列中放线程的时候出现竞态问题的。使用的步骤：1.使用pthread_mutex_lock上锁2.调用pthread_cond_wait2.1将当前线程放入队列2.2解锁2.3休眠2.4获取锁（PS：此时是为了防止出入队列冲突 假设就剩一个元素，是先进还是先出 要争抢一个锁才行） 2.5休眠状态退出3.你的程序4.使用pthread_mutex_unlock解锁参数：@cond:条件变量的地址@mutex:互斥锁返回值：成功返回0，失败返回非零4.给休眠的线程发信号或者广播int pthread_cond_signal(pthread_cond_t *cond);功能：唤醒(至少)一个休眠的线程参数：@cond:条件变量的地址返回值：成功返回0，失败返回非零int pthread_cond_broadcast(pthread_cond_t *cond);功能：唤醒所有休眠的线程参数：@cond:条件变量的地址返回值：成功返回0，失败返回非零     5.销毁条件变量     int pthread_cond_destroy(pthread_cond_t *cond);功能：销毁条件变量参数：@cond:条件变量的地址返回值：成功返回0，失败返回非零 ，

实例：

一个生产者线程多个消费者线程（同步）

#include <head.h>
pthread_mutex_t lock; // 定义互斥锁
pthread_cond_t cond;  // 定义条件变量
void *thread1(void *arg)
{while(1){sleep(1);//sleep（1）一下 调用thread2的线程全部进入休眠了 printf("我生产了一部手机..\n");pthread_cond_signal(&cond);// pthread_cond_broadcast(&cond);}
}
void *thread2(void *arg)
{while(1){pthread_mutex_lock(&lock);pthread_cond_wait(&cond,&lock);printf("%#lx:购买了一部手机\n",pthread_self());pthread_mutex_unlock(&lock);}
}int main(int argc, const char *argv[])
{pthread_t tid1, tid2, tid3, tid4, tid5;pthread_mutex_init(&lock, NULL); // 初始化锁pthread_cond_init(&cond, NULL);  // 初始化条件变量if ((errno = pthread_create(&tid1, NULL, thread1, NULL)) != 0){perror("pthread create1 error");exit(-1);}if ((errno = pthread_create(&tid2, NULL, thread2, NULL)) != 0){perror("pthread create2 error");exit(-1);}if ((errno = pthread_create(&tid3, NULL, thread2, NULL)) != 0){perror("pthread create3 error");exit(-1);}if ((errno = pthread_create(&tid4, NULL, thread2, NULL)) != 0){perror("pthread create4 error");exit(-1);}if ((errno = pthread_create(&tid5, NULL, thread2, NULL)) != 0){perror("pthread create5 error");exit(-1);}printf("tid1 = %#lx,tid2 = %#lx,tid3 = %#lx,tid4 = %#lx,tid5 = %#lx\n", tid1, tid2, tid3, tid4, tid5);pthread_join(tid1, NULL);pthread_join(tid2, NULL);pthread_join(tid3, NULL);pthread_join(tid4, NULL);pthread_join(tid5, NULL);return 0;
}

运行结果

这篇关于线程间通信方式（互斥（互斥锁）与同步（无名信号量、条件变量））的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1089257。

相关文章

nginx upstream六种方式分配小结

nginx upstream六种方式分配小结

《nginxupstream六种方式分配小结》本文主要介绍了nginxupstream六种方式分配小结,包括轮询、加权轮询、IP哈希、公平轮询、URL哈希和备份服务器,具有一定的参考价格,感兴趣的可... 目录1　轮询（默认）2　weight3　ip_hash4　fair（第三方）5　url_hash（第三
阅读更多...
Spring Boot 中正确地在异步线程中使用 HttpServletRequest的方法

Spring Boot 中正确地在异步线程中使用 HttpServletRequest的方法

《SpringBoot中正确地在异步线程中使用HttpServletRequest的方法》文章讨论了在SpringBoot中如何在异步线程中正确使用HttpServletRequest的问题,... 目录前言一、问题的来源：为什么异步线程中无法访问 HttpServletRequest？1. 请求上下文与线
阅读更多...
在 Spring Boot 中使用异步线程时的 HttpServletRequest 复用问题记录

在 Spring Boot 中使用异步线程时的 HttpServletRequest 复用问题记录

《在SpringBoot中使用异步线程时的HttpServletRequest复用问题记录》文章讨论了在SpringBoot中使用异步线程时,由于HttpServletRequest复用导致... 目录一、问题描述：异步线程操作导致请求复用时 Cookie 解析失败1. 场景背景2. 问题根源二、问题详细分
阅读更多...
linux打包解压命令方式

linux打包解压命令方式

《linux打包解压命令方式》文章介绍了Linux系统中常用的打包和解压命令,包括tar和zip,使用tar命令可以创建和解压tar格式的归档文件,使用zip命令可以创建和解压zip格式的压缩文件,每... 目录Lijavascriptnux 打包和解压命令打包命令解压命令总结linux 打包和解压命令打
阅读更多...
Python中常用的四种取整方式分享

Python中常用的四种取整方式分享

《Python中常用的四种取整方式分享》在数据处理和数值计算中,取整操作是非常常见的需求,Python提供了多种取整方式,本文为大家整理了四种常用的方法,希望对大家有所帮助... 目录引言向零取整（Truncate）向下取整（Floor）向上取整（Ceil）四舍五入（Round）四种取整方式的对比综合示例应
阅读更多...
Rust格式化输出方式总结

Rust格式化输出方式总结

《Rust格式化输出方式总结》Rust提供了强大的格式化输出功能,通过std::fmt模块和相关的宏来实现,主要的输出宏包括println!和format!,它们支持多种格式化占位符,如{}、{:?}... 目录Rust格式化输出方式基本的格式化输出格式化占位符Format 特性总结Rust格式化输出方式
阅读更多...
Java中将异步调用转为同步的五种实现方法

Java中将异步调用转为同步的五种实现方法

《Java中将异步调用转为同步的五种实现方法》本文介绍了将异步调用转为同步阻塞模式的五种方法：wait/notify、ReentrantLock+Condition、Future、CountDownL... 目录异步与同步的核心区别方法一：使用wait/notify + synchronized代码示例关键
阅读更多...
将java程序打包成可执行文件的实现方式

将java程序打包成可执行文件的实现方式

《将java程序打包成可执行文件的实现方式》本文介绍了将Java程序打包成可执行文件的三种方法：手动打包（将编译后的代码及JRE运行环境一起打包）,使用第三方打包工具（如Launch4j）和JDK自带... 目录1.问题提出2.如何将Java程序打包成可执行文件2.1将编译后的代码及jre运行环境一起打包2
阅读更多...
C++一个数组赋值给另一个数组方式

C++一个数组赋值给另一个数组方式

《C++一个数组赋值给另一个数组方式》文章介绍了三种在C++中将一个数组赋值给另一个数组的方法：使用循环逐个元素赋值、使用标准库函数std::copy或std::memcpy以及使用标准库容器,每种方... 目录C++一个数组赋值给另一个数组循环遍历赋值使用标准库中的函数 std::copy 或 std::
阅读更多...
spring-boot-starter-thymeleaf加载外部html文件方式

spring-boot-starter-thymeleaf加载外部html文件方式

《spring-boot-starter-thymeleaf加载外部html文件方式》本文介绍了在SpringMVC中使用Thymeleaf模板引擎加载外部HTML文件的方法,以及在SpringBoo... 目录1.Thymeleaf介绍2.springboot使用thymeleaf2.1.引入spring
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2