2024.2.22

  • 开发
  • 36

1.


#include <myhead.h>
 
//临界资源
int num=10;
 
//创建一个互斥锁
pthread_mutex_t mutex;
 
//任务一
void *task1(void *arg)
{
	//获取锁资源
	pthread_mutex_lock(&mutex);
	
	num=123;
	sleep(3);
	printf("task1:num=%d\n",num);
 
	//释放锁资源
	pthread_mutex_unlock(&mutex);
	//退出线程
	pthread_exit(NULL);
}
//任务二
void *task2(void *arg)
{
	//获取锁资源
	pthread_mutex_lock(&mutex);
	
	num++;
	sleep(1);
	printf("task2:num=%d\n",num);
	
	//释放锁资源
	pthread_mutex_unlock(&mutex);
 
	//退出线程
	pthread_exit(NULL);
}
/*************************主程序************************/
int main(int argc, const char *argv[])
{
	//初始化互斥锁
	pthread_mutex_init(&mutex,NULL);
 
	//创建两个线程
	pthread_t tid1,tid2;
 
	if(pthread_create(&tid1,NULL,task1,NULL) != 0){
		printf("create tid1 error\n");
		return -1;
	}
	if(pthread_create(&tid2,NULL,task2,NULL) != 0){
		printf("create tid1 error\n");
		return -1;
	}
	printf("tid1=%#lx tid2=%#lx\n",tid1,tid2);
	//回收资源
	pthread_join(tid1,NULL);
	pthread_join(tid2,NULL);
 
	//销毁互斥锁
	pthread_mutex_destroy(&mutex);
	return 0;
}

2.

#include <myhead.h>
 
//定义一个无名信号量
sem_t sem1;
sem_t sem2;
sem_t sem3;
//任务1
void *task1(void *arg)
{
	int num=4;
	while(num--)
	{
		//申请资源
		sem_wait(&sem3);
 
		sleep(1);
		printf("A");
		fflush(stdout);           //刷新缓冲区
 
		//释放资源
		sem_post(&sem1);
	}
	//退出线程
	pthread_exit(NULL);
 
}
//任务2
void *task2(void *arg)
{
	int num=4;
	while(num--)
	{
		//申请资源
		sem_wait(&sem1);
		sleep(1);
		printf("B");
		fflush(stdout);           //刷新缓冲区
		//释放资源
		sem_post(&sem2);
	}
	//退出线程
	pthread_exit(NULL);
 
}
//任务3
void *task3(void *arg)
{
	int num=4;
	while(num--)
	{
		//申请资源
		sem_wait(&sem2);
 
		sleep(1);
		printf("C");
		fflush(stdout);           //刷新缓冲区
 
		//释放资源
		sem_post(&sem3);
	}
	//退出线程
	pthread_exit(NULL);
 
}
/*********************主程序********************/
int main(int argc, const char *argv[])
{
	//初始化无名信号量
	sem_init(&sem1,0,0);
	sem_init(&sem2,0,0);
	sem_init(&sem3,0,1);
 
	//创建三个线程
	pthread_t tid1,tid2,tid3;
	if(pthread_create(&tid1,NULL,task1,NULL) != 0){
		printf("create tid1 error\n");
		return -1;
	}
	if(pthread_create(&tid2,NULL,task2,NULL) != 0){
		printf("create tid2 error\n");
		return -1;
	}
	if(pthread_create(&tid3,NULL,task3,NULL) != 0){
		printf("create tid3 error\n");
		return -1;
	}
 
	//回收资源
	pthread_join(tid1,NULL);
	pthread_join(tid2,NULL);
	pthread_join(tid3,NULL);
 
	//销毁无名信号量
	sem_destroy(&sem1);
	sem_destroy(&sem2);
	sem_destroy(&sem3);
 
	puts("");
	return 0;
}

3.


#include <myhead.h>
//定义条件变量
pthread_cond_t cond;
 
//定义互斥锁变量
pthread_mutex_t mutex;
 
//生产者
void *task1(void *arg)
{
	int num=3;
	while(num--)
	{
		sleep(1);
		printf("%#lx:摘了一个苹果\n",pthread_self());
 
		//唤醒一个进程
		pthread_cond_signal(&cond);
	}
	//退出线程
	pthread_exit(NULL);
}
//消费者
void *task2(void *arg)
{
	
	//获取锁资源
	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[])
{
	//初始化条件变量
	pthread_cond_init(&cond,NULL);
	//初始化互斥锁变量
	pthread_mutex_init(&mutex,NULL);
	
	//创建生产者与消费者线程
	pthread_t tid1,tid2,tid3,tid4;
	if(pthread_create(&tid1,NULL,task1,NULL)!=0){
		printf("create tid1 error\n");
		return -1;
	}
	if(pthread_create(&tid2,NULL,task2,NULL)!=0){
		printf("create tid2 error\n");
		return -1;
	}
	if(pthread_create(&tid3,NULL,task2,NULL)!=0){
		printf("create tid3 error\n");
		return -1;
	}
	if(pthread_create(&tid4,NULL,task2,NULL)!=0){
		printf("create tid4 error\n");
		return -1;
	}
 
	//回收资源
	pthread_join(tid1,NULL);
	pthread_join(tid2,NULL);
	pthread_join(tid3,NULL);
	pthread_join(tid4,NULL);
	//销毁条件变量
	pthread_cond_destroy(&cond);
	//销毁互斥锁
	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;
	}
 
	//创建子进程
	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)
		{
			//清空数组内容
			bzero(rbuf,sizeof(rbuf));
			//从管道文件中读取数据
			read(pipefd[0],rbuf,sizeof(rbuf));
 
			printf("从父进程传来的数据:%s\n",rbuf);
			//判断写入的数据
			if(strcmp(rbuf,"quit")==0){
				break;
			}
			
		}
		//关闭管道读端
		close(pipefd[0]);
		//退出子进程
		exit(EXIT_SUCCESS);
	}else{
		perror("pid error");
		return -1;
	}
 
	return 0;
}

5.

create.c

#include<myhead.h>
int main(int argc, const char *argv[])
{
	if(mkfifo("./im_file",0664)==-1){
		perror("im_file error");
		return -1;
	}



	if(mkfifo("./out_file",0664)==-1){
		perror("out_file error");
		return -1;
	}



	getchar();

	system("rm im_file");
	system("rm out_file");
	return 0;
}

im.c

#include<myhead.h>
struct Ione
{
	int im;
	int out;
};


pthread_mutex_t rt;


void *task1(void *arg){



char wbuf[128]="";
	while(1){
	
		pthread_mutex_lock(&rt);

		printf("请输入\n");

		fgets(wbuf,sizeof(wbuf),stdin);

		wbuf[strlen(wbuf)-1]==0;


		if(strcmp(wbuf,"exit")==0)
			break;
	
	}

		pthread_mutex_unlock(&rt);

}
void *task2(void *arg){

struct Ione buf=*((struct Ione *)arg);
int out=buf.out;

		pthread_mutex_lock(&rt);

char rbuf[128]="";

	while(1){
	
		bzero(rbuf,sizeof(rbuf));

		read(out,rbuf,sizeof(rbuf));

		printf("收到的数据为:%s\n",rbuf);

		if(strcmp(rbuf,"exit")==0)
			break;

	}

		pthread_mutex_unlock(&rt);
}


int main(int argc, const char *argv[])
{

	int im=-1;

	if(im=open("./im_file",O_WRONLY)==-1){
		perror("open error");
		return -1;
	}

	
	int out=-1;

	if(im=open("./out_file",O_RDONLY)==-1){
		perror("open error");
		return -1;
	}
	
	pthread_mutex_init(&rt,NULL);


	struct Ione sum={im,out};


	pthread_t tid1=-1,tid2=-1;

	if(pthread_create(&tid1,NULL,task1,&sum));
	if(pthread_create(&tid2,NULL,task2,&sum));


pthread_mutex_destroy(&rt);	
	close(im);
	close(out);

	return 0;
}

out.c

#include<myhead.h>
struct Ione
{
	int im;
	int out;
};


pthread_mutex_t rt;


void *task1(void *arg){



char wbuf[128]="";
	while(1){
	
		pthread_mutex_lock(&rt);

		printf("请输入\n");

		fgets(wbuf,sizeof(wbuf),stdin);

		wbuf[strlen(wbuf)-1]==0;


		if(strcmp(wbuf,"exit")==0)
			break;
	
	}

		pthread_mutex_unlock(&rt);

}
void *task2(void *arg){

struct Ione buf=*((struct Ione *)arg);
int out=buf.out;

		pthread_mutex_lock(&rt);

char rbuf[128]="";

	while(1){
	
		bzero(rbuf,sizeof(rbuf));

		read(out,rbuf,sizeof(rbuf));

		printf("收到的数据为:%s\n",rbuf);

		if(strcmp(rbuf,"exit")==0)
			break;

	}

		pthread_mutex_unlock(&rt);
}


int main(int argc, const char *argv[])
{

	int im=-1;

	if(im=open("./out_file",O_WRONLY)==-1){
		perror("open error");
		return -1;
	}

	
	int out=-1;

	if(im=open("./im_file",O_RDONLY)==-1){
		perror("open error");
		return -1;
	}
	
	pthread_mutex_init(&rt,NULL);


	struct Ione sum={im,out};


	pthread_t tid1=-1,tid2=-1;

	if(pthread_create(&tid1,NULL,task1,&sum));
	if(pthread_create(&tid2,NULL,task2,&sum));


pthread_mutex_destroy(&rt);	
	close(im);
	close(out);

	return 0;
}

阅读全部

相关推荐

  1. 20240222作业

    2024-02-23 13:26:04       43 阅读

最近更新

  3. docker php8.1+nginx base 镜像 dockerfile 配置

    2024-02-23 13:26:04       94 阅读

  4. Could not load dynamic library ‘cudart64_100.dll‘

    2024-02-23 13:26:04       101 阅读

  9. 在Django里面运行非项目文件

    2024-02-23 13:26:04       82 阅读

  19. Python语言-面向对象

    2024-02-23 13:26:04       91 阅读

  20. 如何分清楚常见的 Git 分支管理策略Git Flow、GitHub Flow 和 GitLab Flow

    2024-02-23 13:26:04       85 阅读

热门阅读

  5. idea打开项目白屏

    2024-02-23 13:26:04       65 阅读

  9. OpenAI推出首个AI视频模型Sora：重塑视频创作与体验

    2024-02-23 13:26:04       49 阅读

  10. 【LeetCode每日一题】单调栈316去除重复字母

    2024-02-23 13:26:04       55 阅读

  11. uniApp中 将2一张图片叠加到指定位置

    2024-02-23 13:26:04       52 阅读

  12. 物联网中基于WiFi的室内温度检测系统设计

    2024-02-23 13:26:04       43 阅读

  18. EPSON机器人与PC上位机软件C#网络TCP通讯

    2024-02-23 13:26:04       50 阅读

  21. SpringBoot 使用 JWT 保护 Rest Api 接口

    2024-02-23 13:26:04       42 阅读

  22. websoket

    2024-02-23 13:26:04       50 阅读

  23. vue+electron 自动更新

    2024-02-23 13:26:04       48 阅读

  24. 【LeetCode周赛】第 385 场周赛

    2024-02-23 13:26:04       62 阅读
  25. QT-Day2

    QT-Day2

    2024-02-23 13:26:04      44 阅读

  26. 网页数据的解析提取（Beautiful Soup库详解）

    2024-02-23 13:26:04       53 阅读

  29. 冬眠...

    2024-02-23 13:26:04       56 阅读

  30. 分布式场景怎么Join，一文讲解

    2024-02-23 13:26:04       50 阅读