IO进程线程day6

news2024/9/24 9:24:59

思维导图：

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

#include<myhead.h>
int num=520;//临界资源

//创建一个互斥锁变量
pthread_mutex_t mutex;

//定义任务１函数
void *task1(void *arg)
{
	printf("我是任务１：\n");

	//3.获取锁资源
	pthread_mutex_lock(&mutex);

	num=1314;
	sleep(3);
	printf("task1:num=%d\n",num);

	//4.释放锁资源
	pthread_mutex_unlock(&mutex);
}

//定义任务２函数
void *task2(void *arg)
{
	printf("我是任务２：\n");

	//获取锁资源
	pthread_mutex_lock(&mutex);

	num++;
	sleep(1);
	printf("task2:num=%d\n",num);

	//释放锁资源
	pthread_mutex_unlock(&mutex);

}
int main(int argc, const char *argv[])
{
	//2.初始化互斥锁
	pthread_mutex_init(&mutex,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);

	//回收线程资源
	pthread_join(tid1,NULL);
	pthread_join(tid2,NULL);

	//5.销毁锁资源
	pthread_mutex_destroy(&mutex);

	return 0;
}

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

#include<myhead.h>
//1.创建无名信号量
sem_t sem;

//定义生产者线程
void *task1(void *arg)
{
	int num=5;
	while(num--)
	{
		sleep(1);
		printf("我生产了一个煤气罐\n");

		//4.释放资源
		sem_post(&sem);
	}
	//退出线程
	pthread_exit(NULL);
}
//定义消费者线程
void *task2(void *arg)
{
	int num=5;
	while(num--)
	{
		//申请资源
		sem_wait(&sem);


		printf("我消费了一个煤气罐\n");

	}
	//退出线程
	pthread_exit(NULL);
}

int main(int argc, const char *argv[])
{
	//２．初始化无名信号量
	sem_init(&sem,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);

	//回收线程资源
	pthread_join(tid1,NULL);
	pthread_join(tid2,NULL);

	//释放无名信号量
	sem_destroy(&sem);

	return 0;
}

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

#include<myhead.h>
//1.定义条件变量
pthread_cond_t cond;

//11.定义互斥锁变量
pthread_mutex_t mutex;

//定义生产者线程
void *task1(void *arg)
{
	int num=5;
	while(num--)
	{
		sleep(1);
		printf("%#lx:生产了一辆特斯拉\n",pthread_self());

		//唤醒一个消费者
		//pthread_cond_signal(&cond);
	}
	//唤醒所有的等待线程
	pthread_cond_broadcast(&cond);

	//退出线程
	//pthread_exit(NULL);
}
//定义消费者线程
void *task2(void *arg)
{
	//33.上锁
	pthread_mutex_lock(&mutex);

	//进入等待队列
	pthread_cond_wait(&cond,&mutex);

	printf("%#lx:消费了一辆特斯拉\n",pthread_self());

	//解锁
	pthread_mutex_unlock(&mutex);

	//退出线程
	pthread_exit(NULL);
}//定义消费者线程
void *task3(void *arg)
{
	//33.上锁
	pthread_mutex_lock(&mutex);

	//进入等待队列
	pthread_cond_wait(&cond,&mutex);

	printf("%#lx:消费了一辆特斯拉\n",pthread_self());

	//解锁
	pthread_mutex_unlock(&mutex);

	//退出线程
	pthread_exit(NULL);
}
//定义消费者线程
void *task4(void *arg)
{
	//33.上锁
	pthread_mutex_lock(&mutex);

	//进入等待队列
	pthread_cond_wait(&cond,&mutex);

	printf("%#lx:消费了一辆特斯拉\n",pthread_self());

	//解锁
	pthread_mutex_unlock(&mutex);

	//退出线程
	pthread_exit(NULL);
}
//定义消费者线程
void *task5(void *arg)
{
	//33.上锁
	pthread_mutex_lock(&mutex);

	//进入等待队列
	pthread_cond_wait(&cond,&mutex);

	printf("%#lx:消费了一辆特斯拉\n",pthread_self());

	//解锁
	pthread_mutex_unlock(&mutex);

	//退出线程
	pthread_exit(NULL);
}
//定义消费者线程
void *task6(void *arg)
{
	//33.上锁
	pthread_mutex_lock(&mutex);

	//进入等待队列
	pthread_cond_wait(&cond,&mutex);

	printf("%#lx:消费了一辆特斯拉\n",pthread_self());

	//解锁
	pthread_mutex_unlock(&mutex);

	//退出线程
	pthread_exit(NULL);
}
int main(int argc, const char *argv[])
{
	//2.初始化条件变量
	pthread_cond_init(&cond,NULL);

	//初始化互斥锁
	pthread_mutex_init(&mutex,NULL);

	//创建六个线程，一个生产者，五个消费者
	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,task3,NULL)!=0)
	{
		printf("tid3 create error\n");
		return 0;
	}
	if(pthread_create(&tid4,NULL,task4,NULL)!=0)
	{
		printf("tid4 create error\n");
		return 0;
	}
	if(pthread_create(&tid5,NULL,task5,NULL)!=0)
	{
		printf("tid5 create error\n");
		return 0;
	}
	if(pthread_create(&tid6,NULL,task6,NULL)!=0)
	{
		printf("tid6 create error\n");
		return 0;
	}
	

	printf("tid1:%#lx,tid2:%#lx,tid3:%#lx,tid4:%#lx,tid5:%#lx,tid6:%#lx\n",tid1,tid2,tid3,tid4,tid5,tid6);

	//回收线程资源
	pthread_join(tid1,NULL);
	pthread_join(tid2,NULL);
	
	pthread_join(tid3,NULL);
	pthread_join(tid4,NULL);
	pthread_join(tid5,NULL);
	pthread_join(tid6,NULL);
	

	//5.销毁条件变量
	pthread_cond_destroy(&cond);

	//55.销毁互斥锁
	pthread_mutex_destroy(&mutex);

	return 0;
}

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

#include<myhead.h>

int main(int argc, const char *argv[])
{
	//创建管道文件，并返回该管道文件的文件描述符
	int pipefd[2]={0};
	if(pipe(pipefd)==-1)
	{
		perror("pipe error");
		return -1;
	}
	printf("pipefd[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);
		}
	
	}else
	{
		perror("fork error");
		return -1;
	}
	return 0;
}

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

create.c

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

rec.c

#include<myhead.h>

int main(int argc, const char *argv[])
{
	//打开管道文件
	int rfd=-1;
	//以只读的方式打开文件
	if(rfd=open("./myfifo",O_RDONLY)==-1)
	{
		perror("open error");
		return -1;
	}
	//定义容器
	char rbuf[128]="";
	while(1)
	{
		//清空数组
		bzero(rbuf,sizeof(rbuf));

		//读取管道中数据
		read(rfd,rbuf,sizeof(rbuf));

		//输出结果
		printf("收到的数据为：%s\n",rbuf);

		//判断结果
		if(strcmp(rbuf,"quit")==0)
		{
			break;
		}
	}
	//关闭文件
	close(rfd);
	return 0;
}

snd.c

#include<myhead.h>

int main(int argc, const char *argv[])
{
	//打开管道文件
	int wfd=-1;
	//以只写的形式打开文件
	if((wfd=open("./myfifo",O_WRONLY)==-1))
	{
		perror("open error");
		return -1;
	}

	//定义容器
	char wbuf[128]="";
	while(1)
	{
		printf("请输入>>>");
		fgets(wbuf,sizeof(wbuf),stdin);
		wbuf[strlen(wbuf)-1]=0;

		//将数据写入管道
		write(wfd,wbuf,strlen(wbuf));

		//判断结果
		if(strcmp(wbuf,"quit")==0)
		{
			break;
		}
	}

	//关闭文件
	close(wfd);
	return 0;
}

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

create.c

#include<myhead.h>
int main(int argc, const char *argv[])
{
	//创建有名管道文件1
	if(mkfifo("./myfifo1",0664) !=0 )
	{
		perror("myfifo1 error");
		return -1;
	}
	
	//创建有名管道文件2
	if(mkfifo("./myfifo2",0664) !=0 )
	{
		perror("myfifo2 error");
		return -1;
	}
 
	printf("文件创建成功\n");
	//使用getchar阻塞
	getchar();
 
	system("rm myfifo1 myfifo2");
	
	return 0;
}

rec.c

#include<myhead.h>
int main(int argc, const char *argv[])
{
	pid_t pid;
	pid=fork();
	if(pid>0)
	{
		//以只写的形式打开管道文件1
		int wfd = -1;
		if((wfd = open("./myfifo1", O_WRONLY)) == -1)
		{
			perror("open error");
			return -1;
		}
 
		//向管道文件1中循环写入数据
		char wbuf[128]="";
		while(1)
		{
			//清空内容
			bzero(wbuf, sizeof(wbuf));
 
			//从终端输入数据
			printf("请输入：\n");
 
			//刷新缓存区
			fflush(stdout);
 
			//从终端读取数据
			read(0, wbuf, sizeof(wbuf));
			wbuf[strlen(wbuf)-1] = '\0';
 
			write(wfd, wbuf, sizeof(wbuf));
 
			if(strcmp(wbuf,"quit") == 0)
				break;
		}
	}
	else if(pid==0)
	{
		//以只读的形式打开管道文件2
		int rfd = -1;
		if((rfd = open("./myfifo2", O_RDONLY)) == -1)
		{
			perror("open error");
			return -1;
		}
 
		//向管道文件2中循环写入数据
		char rbuf[128]="";
		while(1)
		{
			//清空内容
			bzero(rbuf, sizeof(rbuf));
 
			//从管道2中读取数据
			read(rfd, rbuf, sizeof(rbuf));
 
			printf("收到消息：%s\n",rbuf);
 
			//判断结束
			if(strcmp(rbuf,"quit") == 0)
				break;
		}
		exit(EXIT_SUCCESS);
	}
 
	wait(NULL);
 
	return 0;
}

snd.c

#include<myhead.h>
int main(int argc, const char *argv[])
{
	pid_t pid;
	pid=fork();
	if(pid>0)
	{
		//以只读的形式打开管道文件1
		int rfd = -1;
		if((rfd = open("./myfifo1", O_RDONLY)) == -1)
		{
			perror("open error");
			return -1;
		}
 
		//向管道文件1中循环写入数据
		char rbuf[128]="";
		while(1)
		{
			//清空内容
			bzero(rbuf, sizeof(rbuf));
 
			//从管道1中读取数据
			read(rfd, rbuf, sizeof(rbuf));
 
			printf("收到消息：%s\n",rbuf);
 
			//判断结束
			if(strcmp(rbuf,"quit") == 0)
				break;
		}
	}
	else if(pid==0)
	{
		//以只写的形式打开管道文件2
		int wfd = -1;
		if((wfd = open("./myfifo2", O_WRONLY)) == -1)
		{
			perror("open error");
			return -1;
		}
 
		//向管道文件2中循环写入数据
		char wbuf[128]="";
		while(1)
		{
			//清空内容
			bzero(wbuf, sizeof(wbuf));
 
			//从终端输入数据
			printf("请输入：\n");
 
			//刷新缓存区
			fflush(stdout);
 
			//从终端读取数据
			read(0, wbuf, sizeof(wbuf));
			wbuf[strlen(wbuf)-1] = '\0';
 
			write(wfd, wbuf, sizeof(wbuf));
 
			if(strcmp(wbuf,"quit") == 0)
				break;
		}
		exit(EXIT_SUCCESS);
	}
 
	wait(NULL);
 
	return 0;
}

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

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

相关文章

程序员可以做哪些副业？

程序员可以做哪些副业？

如果你经常玩知乎、看公众号&#xff08;软件、工具、互联网这几类的&#xff09;你就会发现&#xff0c;好多资源连接都变成了夸克网盘、迅雷网盘的资源链接。 例如&#xff1a;天涯神贴&#xff0c;基本上全是夸克、UC、迅雷网盘的资源链接。 有资源的前提下&#xff0c;迅雷…
阅读更多...
SpringCloud全家桶---常用微服务组件(1)

SpringCloud全家桶---常用微服务组件(1)

注册中心: *作用: 服务管理 Eureka(不推荐)[读音: 优瑞卡] Nacos(推荐) Zookeeper [读音: 如k波] Consul [读音:康寿] **注册中心的核心功能原理(nacos)** 服务注册: 当服务启动时,会通过rest接口请求的方式向Nacos注册自己的服务 服务心跳: NacosClient 会维护一个定时心跳持…
阅读更多...
【Java 面试题】MySQL与Redis 如何保证双写一致性

【Java 面试题】MySQL与Redis 如何保证双写一致性

目录 方案一：延时双删方案二： 删除缓存重试机制方案三：读取biglog异步删除缓存系列文章版本记录方案一：延时双删 延时双删流程 先删除缓存再更新数据库休眠一会（比如1秒），再次删除缓存。这个休眠一会，一般多久呢？都是1秒？ 这个休眠时间 = 读业务逻辑数据
阅读更多...
七、计算机视觉-图像的ROI区域

七、计算机视觉-图像的ROI区域

文章目录 1、什么是ROI2、ROI如何实现的3、一个案例总结 1、什么是ROI 在计算机视觉中&#xff0c;ROI代表感兴趣区域&#xff08;Region of Interest&#xff09;&#xff0c;它是指图像或视频中被指定为需要特别关注或处理的区域。ROI可以帮助减少计算量&#xff0c;并且在处…
阅读更多...
口吃矫正：1.缓解口吃预感与紧张感的心态引导

口吃矫正：1.缓解口吃预感与紧张感的心态引导

一、我的经验 首先可以看看电影《心灵捕手》的一个片段&#xff1a; 这个片段大致讲的是威尔遇到了一个自己心仪的女生&#xff0c;第一次约会后不敢再约&#xff0c;因为他想保持第一次约会时给女生的完美状态&#xff1b;心理医生查克则给威尔讲述了他的妻子“睡觉时放屁把自…
阅读更多...
学习JAVA的第三天（基础）

学习JAVA的第三天（基础）

目录 流程控制语句 顺序结构 分支结构 循环结构 分类&#xff1a; 练习 跳转控制语句 练习 数组 数组介绍 数组的定义和静态初始化 数组定义 数组的静态初始化 数组元素访问 数组遍历 数组动态初始化 JAVA内存分配 流程控制语句 顺序结构 是Java程序默认的执行流程…
阅读更多...
Nginx跳转模块之location

Nginx跳转模块之location

目录 一、location模块基本介绍 1、location模块是什么&#xff1f; 2、三种匹配类别 3、常用的匹配规则 4、匹配优先级 优先级总结 二、location模块使用实例 1、精确匹配优先级小于一般匹配的特殊情况 2、解决方法 3、实际网站中使用的三个匹配规则 ①第一个必选规…
阅读更多...
MyBatis--02-1- MybatisPlus----条件构造器

MyBatis--02-1- MybatisPlus----条件构造器

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 前言AbstractWrapper 条件构造器官网文档https://baomidou.com/pages/10c804/#abstractwrapper](https://baomidou.com/pages/10c804/#abstractwrapper)![在这里插入…
阅读更多...
MyBatisPlus：PG数组类型自动映射问题

MyBatisPlus：PG数组类型自动映射问题

引言： PostGreSQL数据库提供了丰富的数据类型，通过查看官网文档，我们也可以发现，PG也提供了对数组类型的支持。 但是在实际开发中，我们通常是使用MyBatis/MyBatisPlus这种半自动ORM映射框架来实现数据库/表数据基本的增删改查，以及其它操作。那么，问题来了，如何…
阅读更多...
Web安全之浅见

Web安全之浅见

备注&#xff1a;这是我在2017年在自己的网站上写的文章&#xff0c;今天迁移过来。 昨天去参加了公司组织的一个关于网络安全的培训&#xff0c;了解了很多关于网络安全方面的知识&#xff0c;也才意识到网络安全是一项极其重要的领域。 本篇文章主要聊聊Web安全。不过我对于网…
阅读更多...
大模型相关论文笔记

大模型相关论文笔记

Retrieval-Augmented Generation for Knowledge-Intensive NLP Tasks 用于知识密集型NLP任务的检索增强生成 Facebook 2020 PDF CODE &#xff08;论文代码链接已失效&#xff0c;以上是最新链接&#xff09; 引言 大模型有幻觉问题&#xff08;hallucinations&#xff09;&…
阅读更多...
串的相关题目

串的相关题目

于是他错误的点名开始了 我发现有关hash得题目有些是可以通过map数组来完成的&#xff1a;何为map数组&#xff0c;我们先思考一下最简单的桶的排序&#xff0c;桶排序是将我们需要数字最为下标输进数组中&#xff0c;而数组是存放的数字是这个数字出现的次数&#xff0c;但是由…
阅读更多...
【Python Scrapy】分布式爬虫利器

【Python Scrapy】分布式爬虫利器

在当今信息爆炸的时代&#xff0c;获取大规模数据对于许多应用至关重要。而分布式爬虫作为一种强大的工具&#xff0c;在处理大量数据采集和高效爬取方面展现了卓越的能力。 本文将深入探讨分布式爬虫的实际应用场景&#xff0c;通过代码示例演示其在提升爬取效率、保障系统稳定…
阅读更多...
Day32 进程Process

Day32 进程Process

文章目录 1.什么是进程1.1 概念1.2 特点1.3 进程段1.4 进程分类1.5 进程状态1.6 进程状态切换图1.7 调度进程 2.进程函数接口2.1 创建进程 fork()2.2 回收资源函数2.3 结束进程2.4 获取进程号 3.exec函数族&#xff08;了解&#xff09;4.守护进程 Daemon4.1 守护进程的特点4.2…
阅读更多...
【xss跨站漏洞】xss漏洞利用工具beef的安装

【xss跨站漏洞】xss漏洞利用工具beef的安装

安装环境 阿里云服务器&#xff0c;centos8.2系统&#xff0c;docker docker安装 前提用root用户 安装docker yum install docker 重启docker systemctl restart docker beef安装 安装beef docker pull janes/beef 绑定到3000端口 docker run --rm -p 3000:3000 janes/beef …
阅读更多...
贷齐乐系统最新版SQL注入（无需登录绕过WAF可union select跨表查询）

贷齐乐系统最新版SQL注入（无需登录绕过WAF可union select跨表查询）

一、环境 已上传资源&#xff08;daiqile&#xff09; 二、代码解释 1.1Request 不管get请求还是post请求都可以接收到 1.2过滤的还挺多 1.3第二个WAF把数据分为两个了一个Key一个value&#xff0c;全是explode的功劳 1.4submit是if进入的前提 很明显走进来了 1.5那我们在这…
阅读更多...
2024年上海高考数学备考：历年选择题真题练一练（2014~2023）

2024年上海高考数学备考：历年选择题真题练一练（2014~2023）

今天距离2024年高考还有三个多月的时间&#xff0c;今天我们来看一下2014~2023年的上海高考数学的选择题&#xff0c;从过去十年的真题中随机抽取5道题&#xff0c;并且提供解析。 后附六分成长独家制作的在线练习集&#xff0c;科学、高效地反复刷这些真题&#xff0c;吃透真…
阅读更多...
回显服务器的制作方法

回显服务器的制作方法

文章目录 客户端和服务器TCP和UDP的特点UDP socket api的使用DatagramSocketDatagramPacketInetSocketAddress API 做一个简单的回显服务器UDP版本的回显服务器TCP版本的回显服务器 客户端和服务器 在网络中&#xff0c;主动发起通信的一方是客户端&#xff0c;被动接受的这一方…
阅读更多...
【Nacos】构建云原生应用的动态服务发现、配置管理和服务管理平台【企业级生产环境集群搭建应用】

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

基础描述 一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台Nacos 致力于帮助您发现、配置和管理微服务。Nacos 提供了一组简单易用的特性集&#xff0c;帮助您快速实现动态服务发现、服务配置、服务元数据及流量管理。Nacos 帮助您更敏捷和容易地构建、交付和…
阅读更多...
API接口测试工具的使用指南

API接口测试工具的使用指南

API接口测试是确保软件系统正常运作的关键步骤。API接口测试工具可以帮助开发人员和测试人员验证API的功能、性能和安全性。本文将介绍API接口测试工具的基本使用方法&#xff0c;以便有效地进行接口测试。 1. 选择合适的API测试工具 在开始API接口测试之前&#xff0c;首先需要…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023