IOday5

一、思维导图

二、练习

使用两个线程完成两个文件的拷贝，分支线程1拷贝前一半，分支线程2拷贝后一半，主线程回收两个分支线程的资源

#include<myhead.h>

//定义结构体存储需要传到线程函数中的内容
struct Buf
{
const char *file[2];//存储源文件和目标文件文件名
int start; //拷贝开始位置
int len; //存储需要拷贝的长度
};

void *copy(void *buf)
{
//判断传过来的信息
//前半部分拷贝
//解引用结构体参数
int start = ((struct Buf*)buf)->start;
int len = ((struct Buf*)buf)->len;
const char *src =((struct Buf*)buf)->file[0];
const char *dest = ((struct Buf*)buf)->file[1];

//打开源文件和目标文件描述符
int sfd = open(src,O_RDONLY);
if(-1 == sfd)
{
perror("open src error");
}

int dfd = open(dest,O_WRONLY);
if(-1 == dfd)
{
perror("open dest error");
}

//根据参数判断拷贝部分
if(start == 0)
{
//线程1执行的内容
//拷贝前一半
printf("1start = %d,len = %d\n",start,len);
//移动文件光标
lseek(sfd,start,SEEK_SET);
lseek(dfd,start,SEEK_SET);

}
//后半部分拷贝
else if(start != 0)
{
//线程2执行的内容
//拷贝后一半
printf("2start = %d,len = %d\n",start,len);
//移动文件光标
lseek(sfd,start,SEEK_SET);
lseek(dfd,start,SEEK_SET);

}

//定义拷贝容器
char Cop[128];
int sum = 0; //累加拷贝的字节数量
while(1)
{
int res = read(sfd,Cop,sizeof(Cop));
sum += res; //将读取的个数累加

if(res==0 || sum>len)
{
write(dfd,Cop,res-(sum-len)); //前半部分最后一次拷贝写入到目标文件中
break;
}
//写入到目标文件中
write(dfd,Cop,res);
}

printf("拷贝成功\n");

//退出线程
pthread_exit(NULL);


}

int main(int argc, const char *argv[])
{
//判断终端数入
if(argc != 3)
{
printf("input error\n");
printf("usage:./a.out srcfile destfile\n");
return -1;
}

//打开源文件和目标文件描述符
int sfd = open(argv[1],O_RDONLY);
if(-1 == sfd)
{
perror("open src error");
return -1;
}

int dfd = open(argv[2],O_WRONLY|O_CREAT|O_TRUNC,0664);
if(-1 == dfd)
{
perror("open dest error");
return -1;
}

//计算出源文件长度以及线程2拷贝开始位置
int len = lseek(sfd,0,SEEK_END);
printf("len= %d\n",len);

//关闭文件
close(sfd);
close(dfd);

//定义两个容器分别传输两个线程的参数
struct Buf buf1 ={{argv[1],argv[2]},0,len/2};
struct Buf buf2 ={{argv[1],argv[2]},len/2,len-len/2};

//定义线程变量
pthread_t tid1,tid2;

//创建两个线程
if(pthread_create(&tid1,NULL,copy,&buf1) != 0)
{
printf("tid1创建失败\n");
return -1;
}

if(pthread_create(&tid2,NULL,copy,&buf2) != 0)
{
printf("tid2创建失败\n");
return -1;
}

//阻塞等待线程的结束
pthread_join(tid1,NULL);
pthread_join(tid2,NULL);

return 0;
}

原文地址：https://blog.csdn.net/qq_55245263/article/details/140856485

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！