IO线程进程

多线程练习

使用多线程完成两个文件的拷贝，第一个线程拷贝前一半，第二个线程拷贝后一半，主线程回收两个线程的资源

#include <myhead.h>
//创建结构体，传递参数给线程函数
typedef struct 
{
	int start;//拷贝的起始位置
	int end;//拷贝的结束位置
	int source_fd;//被拷贝的源文件
	int dest_fd;//拷贝出来的目标文件
}ThreadArg;
//线程函数　拷贝一半的文件到另一个文件中
void *half_copy(void *arg)
{
	//将参数类型转为 ThreadArg 型
	ThreadArg *thread_arg =(ThreadArg *)arg;
	//将光标固定在起始位置
	//前一半的的时候　读取与写入的起始位置都是０
	//后一半时　读取与写入的起始位置都是都是文件大小的中值
	lseek(thread_arg->source_fd,thread_arg->start,SEEK_SET);
	lseek(thread_arg->dest_fd,thread_arg->start,SEEK_SET);

	//定义一个缓冲区　存储读取被拷贝文件的数据
	char buf[128];
	//定义一个计数的　　　判断读取的总大小有没有超过一半
	//超过文件大小一半时舍弃多余部分后写入
	int sum=0;
	//循环写入
	while(1)
	{
		//计算每次写入的大小
		int res=read(thread_arg->source_fd,buf,sizeof(buf));
		//计算总共读取的大小
		sum+=res;
		//计算文件一半的大小　　函数中需要计算　结束位置减去起始位置
		int len=thread_arg->end - thread_arg->start;
		//读取总大小超过一半　和读取为０是　返回
		if(sum >=len ||res==0)
		{
			//写入最后一次读取的内容
			write(thread_arg->dest_fd,buf,res-(sum-len));
			break;
		}
		//写入内容
		write(thread_arg->dest_fd,buf,res);
	}

}



int main(int argc, const char *argv[])
{
	//打开源文件和目标文件
	int source_fd,dest_fd;
	if((source_fd=open("./02ptread.c",O_RDONLY))==-1)
	{
		perror("open error");
		return -1;
	}
	if((dest_fd=open("./test.txt",O_WRONLY|O_CREAT,0664))==-1)
	{
		perror("open error");
		return -1;
	}

	//计算文件的大小
	int size=lseek(source_fd,0,SEEK_END);
	//文件一半的大小
	int halfsize=size/2;

	//创建两个线程
	pthread_t thread1,thread2;
	//创建两个结构体　arg1 arg2 　给线程函数传参
	ThreadArg arg1 ={0,halfsize,source_fd,dest_fd};
	ThreadArg arg2 ={halfsize,size,source_fd,dest_fd};
	//创建两个线程　结构体 arg1 arg2 作为参数
	pthread_create(&thread1,NULL,half_copy,&arg1);
	pthread_create(&thread2,NULL,half_copy,&arg2);
	//等待两个线程完成
	pthread_join(thread1,NULL);
	pthread_join(thread2,NULL);
	//关闭两个文件和文件描述符
	close(source_fd);
	close(dest_fd);

	return 0;
}

效果图

 思维导图