day05-进程通信

1> 将互斥机制的代码实现重新敲一遍

代码：

#include<myhead.h>int num=520;//临界资源//1.创建互斥锁
pthread_mutex_t fastmutex;//定义任务函数
void *task1(void *arg){printf("1111111\n");//3.临界区上面获取锁资源（上锁）pthread_mutex_lock(&fastmutex);num=1314;sleep(3);printf("task1:num = %d\n",num); //1314//4. 释放锁资源pthread_mutex_unlock(&fastmutex);
}void *task2(void *arg){printf("2222222\n");pthread_mutex_lock(&fastmutex);num++;      //521sleep(1);   //休眠时任务1执行到赋值语句printf("task2:num = %d\n",num);pthread_mutex_unlock(&fastmutex);
}int main(int argc, char const *argv[])
{//2.初始化互斥锁pthread_mutex_init(&fastmutex,NULL);//线程创建pthread_t tid1,tid2;if(pthread_create(&tid1,NULL,task1,NULL)!=0){printf("tid1 create error\n");return 0;}if(pthread_create(&tid2,NULL,task2,NULL)!=0){printf("tid2 create error\n");return 0;}printf("tid1:%#lx, tid2:%#lx\n",tid1,tid2);//回收资源if(pthread_join(tid1,NULL)==0)printf("tid1回收成功\n");if(pthread_join(tid2,NULL)==0)printf("tid2回收成功\n");//5. 销毁锁资源pthread_mutex_destroy(&fastmutex);return 0;
}

结果：

2> 将无名信号量的代码实现重新敲一遍

代码：

#include<myhead.h>//创建无名信号了
sem_t sem;//定义生产者线程
void *task1(void *arg){printf("1111111\n");int num= 5;while(num--){//3.申请资源//    sem_wait(&sem);sleep(1);printf("我生产了一辆车\n");//4.释放资源sem_post(&sem);}pthread_exit(NULL);
}//定义消费者线程
void *task2(void *arg){printf("2222222\n");int num= 5;while(num--){//3.申请资源sem_wait(&sem);printf("我消费了一辆车\n");//4.释放资源//    sem_post(&sem);}pthread_exit(NULL);
}int main(int argc, char const *argv[])
{//初始化无名信号量sem_init(&sem,0,0);//第一个0:表示用于线程的同步//第二个0:表示初始资源为0//创建两个线程，分别是生产者和消费者pthread_t tid1,tid2;if(pthread_create(&tid1,NULL,task1,NULL)!=0){printf("tid1 create error\n");return 0;}if(pthread_create(&tid2,NULL,task2,NULL)!=0){printf("tid2 create error\n");return 0;}printf("tid1:%#lx, tid2:%#lx\n",tid1,tid2);//回收资源if(pthread_join(tid1,NULL)==0)printf("tid1回收成功\n");if(pthread_join(tid2,NULL)==0)printf("tid2回收成功\n");//释放无名信号量sem_destroy(&sem);return 0;
}

结果：

3> 将条件变量的代码实现重新敲一遍

代码：

#include<myhead.h>//1. 定义条件变量
pthread_cond_t cond;//11. 创建互斥锁
pthread_mutex_t fastmutex;//定义生产者线程
void *task1(void *arg){int num= 5;while(num--){sleep(1);printf("%#lx:生产了一辆车\n",pthread_self());//3. 唤醒一个消费者pthread_cond_signal(&cond);}pthread_exit(NULL);
}//定义消费者线程
void *task2(void *arg){//33.临界区上面获取锁资源（上锁）pthread_mutex_lock(&fastmutex);//4. 进入等待队列pthread_cond_wait(&cond,&fastmutex);printf("%#lx:消费了一辆车\n",pthread_self());//54. 释放锁资源pthread_mutex_unlock(&fastmutex);pthread_exit(NULL);
}int main(int argc, char const *argv[])
{//2. 初始化无名信号量pthread_cond_init(&cond,NULL);//22. 初始化互斥锁pthread_mutex_init(&fastmutex,NULL);//创建2个线程，分别是生产者和消费者pthread_t tid1,tid2,tid3,tid4,tid5,tid6;if(pthread_create(&tid1,NULL,task1,NULL)!=0){printf("tid1 create error\n");return 0;}if(pthread_create(&tid2,NULL,task2,NULL)!=0){printf("tid2 create error\n");return 0;}if(pthread_create(&tid3,NULL,task2,NULL)!=0){printf("tid3 create error\n");return 0;}if(pthread_create(&tid4,NULL,task2,NULL)!=0){printf("tid4 create error\n");return 0;}    if(pthread_create(&tid5,NULL,task2,NULL)!=0){printf("tid5 create error\n");return 0;}if(pthread_create(&tid6,NULL,task2,NULL)!=0){printf("tid6 create error\n");return 0;}printf("tid1:%#lx, tid2:%#lx, tid3:%#lx\ntid4:%#lx, tid5:%#lx, tid6:%#lx\n",tid1,tid2,tid3,tid4,tid5,tid6);//回收资源if(pthread_join(tid1,NULL)==0)printf("tid1回收成功\n");if(pthread_join(tid2,NULL)==0)printf("tid2回收成功\n");if(pthread_join(tid3,NULL)==0)printf("tid3回收成功\n");if(pthread_join(tid4,NULL)==0)printf("tid4回收成功\n");if(pthread_join(tid5,NULL)==0)printf("tid5回收成功\n");if(pthread_join(tid6,NULL)==0)printf("tid6回收成功\n");//5. 销毁条件变量pthread_cond_destroy(&cond);//55. 销毁锁资源pthread_mutex_destroy(&fastmutex);return 0;
}

结果：

4> 将无名管道的代码实现重新敲一遍

代码：

#include<myhead.h>int main(int argc, char const *argv[])
{//创建管道文件，并返回该管道文件的文件描述符（最小位分配原则）int pipefd[2]={0};if(pipe(pipefd)==1)PRINT_ERR("");printf("pipedf[0]=%d,pipefd[1]=%d\n",pipefd[0],pipefd[1]);//创建一个子进程pid_t pid=fork();if(pid>0){//父进程//关闭管道的读端close(pipefd[0]);char wbuf[128]="";while(1){bzero(wbuf,sizeof(wbuf));   //清空数组内容fgets(wbuf,sizeof(wbuf),stdin);     //从终端输入数据wbuf[strlen(wbuf)-1]=0;//将数据写入管道文件中write(pipefd[1],wbuf,strlen(wbuf));//对写入的数据进行判断if(strcmp(wbuf,"quit")==0)break;}//关闭写端close(pipefd[1]);wait(NULL);  //阻塞回收子进程资源}else if(pid==0){//子进程//关闭写端close(pipefd[1]);char rbuf[128]="";while(1){//清空rbuf内容bzero(rbuf,sizeof(rbuf));//从管道文件中读取数据read(pipefd[0],rbuf,sizeof(rbuf));//输出rbuf的数据printf("父进程传来的数据为:%s\n",rbuf);//对读取的数据进行判断if(strcmp(rbuf,"quit")==0)break;}//关闭管道的读端close(pipefd[0]);exit(EXIT_SUCCESS);     //退出进程}elsePRINT_ERR("");    return 0;
}

结果：

5> 将有名管道的代码实现重新敲一遍

代码：

#include<myhead.h>int main(int argc, const char *argv[])
{//创建一个管道文件if(mkfifo("./myfifo", 0664) == -1){perror("mkfifo error");return -1;}getchar();       //阻塞system("rm myfifo");return 0;
}
#include<myhead.h>int main(int argc, char const *argv[])
{//打开管道文件int wfd=1;//以只写的形式打开文件if((wfd=open("./myfifo",O_WRONLY))==-1)PRINT_ERR("");//定义容器char wbuf[128]="";while(1){bzero(wbuf,sizeof(wbuf));   //清空数组内容fgets(wbuf,sizeof(wbuf),stdin);     //从终端输入数据wbuf[strlen(wbuf)-1]=0;//将数据写入管道文件中write(wfd,wbuf,strlen(wbuf));//对写入的数据进行判断if(strcmp(wbuf,"quit")==0)break;}return 0;
}

#include<myhead.h>int main(int argc, char const *argv[])
{//打开管道文件int wfd=1;//以只读的形式打开文件if((wfd=open("./myfifo",O_RDONLY))==-1)PRINT_ERR("");//定义容器char rbuf[128]="";while(1){//清空rbuf内容bzero(rbuf,sizeof(rbuf));//将数据写入管道文件中read(wfd,rbuf,sizeof(rbuf));//输出rbuf的数据printf("父进程传来的数据为:%s\n",rbuf);//对读取的数据进行判断if(strcmp(rbuf,"quit")==0)break;}return 0;
}

结果：

6> 使用有名管道完成两个进程的相互通信(提示：可以使用多进程或多线程完成)

代码：

管道文件创建

#include<myhead.h>int main(int argc, const char *argv[])
{//创建一个管道文件if(mkfifo("./myfifo1", 0664) == -1){perror("mkfifo1 error");return -1;}if(mkfifo("./myfifo2", 0664) == -1){perror("mkfifo2 error");return -1;}getchar();       //阻塞system("rm myfifo1");system("rm myfifo2");return 0;
}

线程：

#include<myhead.h>int main(int argc, char const *argv[])
{//创建一个子进程pid_t pid=fork();if(pid>0){//父进程//打开管道文件int wfd = -1;//以只写的形式打开文件if((wfd = open("./myfifo1", O_WRONLY)) == -1){perror("open error");return -1;}//定义容器char wbuf[128] = "";while(1){printf("这里是1号机,请输入>>>");fgets(wbuf, sizeof(wbuf), stdin);wbuf[strlen(wbuf)-1] = 0;//将数据写入有名管道write(wfd, wbuf, strlen(wbuf));//判断结果if(strcmp(wbuf,"quit") == 0)break;}//关闭文件close(wfd);          
//        wait(NULL);  //阻塞回收子进程资源}else if(pid==0){//子进程//打开管道文件int rfd = -1;//以只写读的形式打开文件if((rfd = open("./myfifo2", O_RDONLY)) == -1){perror("open error");return -1;}//定义容器char rbuf[128] = "";while(1){//清空数组bzero(rbuf, sizeof(rbuf));//读取管道中的数据read(rfd, rbuf, sizeof(rbuf));//输出结果printf("\t\t\t\t\t1号机收到的数据为：%s\n", rbuf);//判断结果if(strcmp(rbuf,"quit") == 0)break;}//关闭文件close(rfd);exit(EXIT_SUCCESS);     //退出进程}elsePRINT_ERR("");    return 0;
}

#include<myhead.h>int main(int argc, char const *argv[])
{//创建一个子进程pid_t pid=fork();if(pid>0){//父进程//打开管道文件int rfd = -1;//以只写读的形式打开文件if((rfd = open("./myfifo1", O_RDONLY)) == -1){perror("open error");return -1;}//定义容器char rbuf[128] = "";while(1){//清空数组bzero(rbuf, sizeof(rbuf));//读取管道中的数据read(rfd, rbuf, sizeof(rbuf));//输出结果printf("\t\t\t\t\t2号机收到的数据为：%s\n", rbuf);//判断结果if(strcmp(rbuf,"quit") == 0)break;}//关闭文件close(rfd); //       wait(NULL);//   wait(NULL);  //阻塞回收子进程资源}else if(pid==0){//子进程//打开管道文件int wfd = -1;//以只写的形式打开文件if((wfd = open("./myfifo2", O_WRONLY)) == -1){perror("open error");return -1;}//定义容器char wbuf[128] = "";while(1){printf("这里是2号机,请输入>>>");fgets(wbuf, sizeof(wbuf), stdin);wbuf[strlen(wbuf)-1] = 0;//将数据写入管道write(wfd, wbuf, strlen(wbuf));//判断结果if(strcmp(wbuf,"quit") == 0)break;}//关闭文件close(wfd);      exit(EXIT_SUCCESS);     //退出进程}elsePRINT_ERR("");    return 0;
}

结果：

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/696217.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

LeetCode每日刷题：101. 对称二叉树

LeetCode每日刷题：101. 对称二叉树

题目&#xff1a; 解题思路&#xff1a;可以新写一个函数&#xff0c;从root开始&#xff0c;root的left的头结点将记为lefttree&#xff08;左子树&#xff09;,root的lright的头结点将记为righttree&#xff08;右子树&#xff09;&#xff0c; 然后递归左子树的root.left与右…
阅读更多...
【鸿蒙 HarmonyOS 4.0】TypeScript开发语言

【鸿蒙 HarmonyOS 4.0】TypeScript开发语言

一、背景 HarmonyOS 应用的主要开发语言是 ArkTS&#xff0c;它由 TypeScript&#xff08;简称TS&#xff09;扩展而来&#xff0c;在继承TypeScript语法的基础上进行了一系列优化&#xff0c;使开发者能够以更简洁、更自然的方式开发应用。值得注意的是&#xff0c;TypeScrip…
阅读更多...
Python：Keyboard Interrupt - 当代码遇到“Ctrl+C“时发生了什么？

Python：Keyboard Interrupt - 当代码遇到“Ctrl+C“时发生了什么？

Python&#xff1a;Keyboard Interrupt - 当代码遇到"CtrlC"时发生了什么&#xff1f; &#x1f308; 个人主页&#xff1a;高斯小哥 &#x1f525; 高质量专栏&#xff1a;【Matplotlib之旅&#xff1a;零基础精通数据可视化】 &#x1f4a1; 创作高质量博文&#x…
阅读更多...
Web服务器集群： kylin 部署 Halo博客系统

Web服务器集群： kylin 部署 Halo博客系统

目录 一、实验 1.环境 2. kylin 部署mysql数据库 3. kylin 构建Java运行环境 4. 创建博客使用的数据库 5. kylin 部署 halo博客系统 6. kylin 部署nginx 7. kylin 使用 SSL证书基于https访问部署的博客系统 二、问题 1.mysql安装报错 2.查看mysql数据库报错 3.syste…
阅读更多...
【SQL注入】靶场SQLI DUMB SERIES-24通过二次注入重置用户密码

【SQL注入】靶场SQLI DUMB SERIES-24通过二次注入重置用户密码

先使用已知信息admin/admin登录进去查下题&#xff0c;发现可以修改密码 猜测可能存在的SQL语句&#xff1a;UPDATE user SET password新密码 WHERE user用户名 and password旧密码 假设我们知道有个admin用户&#xff0c;但是不知道其密码&#xff0c;如何可以将其密码重置&…
阅读更多...
杂题——1097: 蛇行矩阵

杂题——1097: 蛇行矩阵

题目描述 蛇形矩阵是由1开始的自然数依次排列成的一个矩阵上三角形。 输入格式 本题有多组数据&#xff0c;每组数据由一个正整数N组成。&#xff08;N不大于100&#xff09; 输出格式 对于每一组数据&#xff0c;输出一个N行的蛇形矩阵。两组输出之间不要额外的空行。矩阵三角…
阅读更多...
如何在群辉7.2中使用Docker搭建容器魔方服务并远程访问【内网穿透】

如何在群辉7.2中使用Docker搭建容器魔方服务并远程访问【内网穿透】

文章目录 1. 拉取容器魔方镜像2. 运行容器魔方3. 本地访问容器魔方4. 群辉安装Cpolar5. 配置容器魔方远程地址6. 远程访问测试7. 固定公网地址 本文主要介绍如何在群辉7.2版本中使用Docker安装容器魔方&#xff0c;并结合Cpolar内网穿透工具实现远程访问本地网心云容器魔方界面…
阅读更多...
MySQL 窗口函数温故知新

MySQL 窗口函数温故知新

本文用于复习数据库窗口函数&#xff0c;希望能够温故知新&#xff0c;也希望读到这篇文章的有所收获。 本文以&#xff1a;MySQL为例 参考文档&#xff1a; https://www.begtut.com/mysql/mysql-window-functions.html 使用的样例数据&#xff1a;https://www.begtut.com/m…
阅读更多...
对象池模式-Object Pool Pattern

对象池模式-Object Pool Pattern

原文地址：https://jaune162.blog/design-pattern/object-pool-pattern/ 原文中可下载高清SVG矢量类图 引言 对象池模式（Object Pool Pattern）是一种创建一组可重用对象的设计模式。它通过维护一个预分配的对象集合，避免了频繁地创建和销毁对象所带来的性能开销。在需要使用…
阅读更多...
力扣_字符串11—实现前缀树（字典树、Trie树）

力扣_字符串11—实现前缀树（字典树、Trie树）

题目 方法 对于每一个节点&#xff0c;初始化一个长度为26的数组&#xff0c;用来存储对应字母子节点的地址对于每一个节点&#xff0c;初始化一个 b o o l bool bool 变量用来表示是否为叶子节点 代码 class Trie { private:vector<Trie*> children vector<Trie…
阅读更多...
ESP8266智能家居（1）——开发环境的搭建

ESP8266智能家居（1）——开发环境的搭建

1.前期介绍 本次打算使用esp8266的开发板——NodeMCU&#xff0c;进行物联网相关项目的学习。开发环境使用Arduino软件。 NodeMCU实物图为&#xff1a; 开发环境截图为&#xff1a; 2.软件下载 我使用的arduino版本为1.8.5&#xff0c;其安装包如下&#xff1a; 【免费】ar…
阅读更多...
学习总结22

学习总结22

解题思路 简单模拟。 代码 #include <bits/stdc.h> using namespace std; long long g[2000000]; long long n; int main() {long long x,y,z,sum0,k0;scanf("%lld",&n);for(x1;x<n;x)scanf("%lld",&g[x]);for(x1;x<n;x){scanf(&qu…
阅读更多...
GEE必须会教程—时间都去哪了（Date参数类型）

GEE必须会教程—时间都去哪了（Date参数类型）

时间和空间是世界存在的两种基本属性&#xff0c;大部分的数据都有特有的通道存储时间信息&#xff0c;用户需要通过获取数据存储的信息&#xff0c;来判断数据的可用性&#xff0c;以及数据在时间上发生的变化。在遥感上&#xff0c;空间数据集合中&#xff0c;时间信息显得更…
阅读更多...
django配置视图并与模版进行数据交互

django配置视图并与模版进行数据交互

目录 安装django 创建一个django项目 项目结构 创建视图层views.py 写入视图函数 创建对应视图的路由 创建模版层 配置项目中的模版路径 创建模版html文件 启动项目 浏览器访问结果 安装django pip install django 创建一个django项目 这里最好用命令行完成&#xf…
阅读更多...
SQL注入之DNSLog外带注入

SQL注入之DNSLog外带注入

一、认识&#xff1a; 什么是dnslog呢&#xff1f; DNS就是域名解析服务&#xff0c;把一个域名转换成对应的IP地址&#xff0c;转换完成之后&#xff0c;DNS服务器就会有一个日志记录本次转换的时间、域名、域名对应的ip、请求方的一些信息&#xff0c;这个日志就叫DNSLog。…
阅读更多...
汉诺塔问题—java详解（附源码）

汉诺塔问题—java详解（附源码）

来源及应用 相传在古印度圣庙中&#xff0c;有一种被称为汉诺塔(Hanoi)的游戏。该游戏是在一块铜板装置上&#xff0c;有三根杆(编号A、B、C)&#xff0c;在A杆自下而上、由大到小按顺序放置64个金盘(如图1)。游戏的目标&#xff1a;把A杆上的金盘全部移到C杆上&#xff0c;并仍…
阅读更多...
【Nacos】构建云原生应用的动态服务发现、配置管理和服务管理平台【企业级生产环境集群搭建应用】

【Nacos】构建云原生应用的动态服务发现、配置管理和服务管理平台【企业级生产环境集群搭建应用】

基础描述 一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台Nacos 致力于帮助您发现、配置和管理微服务。Nacos 提供了一组简单易用的特性集&#xff0c;帮助您快速实现动态服务发现、服务配置、服务元数据及流量管理。Nacos 帮助您更敏捷和容易地构建、交付和…
阅读更多...
猫头虎分享已解决Bug || Spring Error: Request method ‘POST‘ not supported

猫头虎分享已解决Bug || Spring Error: Request method ‘POST‘ not supported

博主猫头虎的技术世界 &#x1f31f; 欢迎来到猫头虎的博客 — 探索技术的无限可能&#xff01; 专栏链接&#xff1a; &#x1f517; 精选专栏&#xff1a; 《面试题大全》 — 面试准备的宝典&#xff01;《IDEA开发秘籍》 — 提升你的IDEA技能&#xff01;《100天精通鸿蒙》 …
阅读更多...
海思3559 yolov5 wk模型部署笔记

海思3559 yolov5 wk模型部署笔记

文章目录 安装3559工具链编译opencv编译项目总结 安装3559工具链 将3559工具链copy到虚拟机上&#xff0c;并解压得到安装包 解压&#xff1a; tar -zxvf aarch64-himix100-linux.tgz解压后会得到安装包文件夹&#xff1a; 安装工具链&#xff1a; sudo ./aarch64-himix100…
阅读更多...
Unity2023.1.19没有PBR Graph?

Unity2023.1.19没有PBR Graph?

Unity2023.1.19没有PBR Graph? 关于Unity2023.1.19没有PBR graph的说法，我没看见管方给出的答案，百度则提到了Unity2020版之后Shader Graph的“全新更新”，之前也没太注意版本的区别，以后项目尽量都留心一下。 之前文章说过，孪生智慧项目推荐使用URP渲染管线，以上的截…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023