一.作业
1、使用两个线程完成两个文件的拷贝,分支线程1拷贝前一半,分支线程2拷贝后一半,主线程回收两个分支线程的资源
#include <myhead.h>
struct Node
{
char *src;
char *dest;
int start;
int len;
};
//定义求源文件大小的函数
int lenmain(const char*src,const char *dest)
{
//以只读的形式打开源文件
int fd1 = open(src,O_RDONLY);
if(fd1==-1)
{
perror("open src error");
return -1;
}
//以创建的形式打开目标文件
int fd2 = open(dest,O_WRONLY|O_CREAT|O_TRUNC, 0664);
if(fd2==-1)
{
perror("open dest error");
return -1;
}
int size = lseek(fd1, 0, SEEK_END);
//关闭文件
close(fd1);
close(fd2);
return size; //将文件大小返回
}
//定义文件拷贝函数
void kaobei(const char*src,const char *dest,int start,int len)
{
//以只读的形式打开源文件
int fd1 = open(src,O_RDONLY);
if(fd1 == -1)
{
perror("open src error");
return ;
}
//以创建的形式打开目标文件
int fd2 = open(dest,O_WRONLY);
if(fd2 == -1)
{
perror("open dest error");
return ;
}
//移动光标位置
lseek(fd1, start, SEEK_SET);
lseek(fd2, start, SEEK_SET);
//定义搬运工
char buf[128] = "";
int sum = 0; //记录拷贝的总个数
while(1)
{
//从源文件中读取数据
int res = read(fd1,buf,sizeof(buf));
sum+=res;//将读取的个数累加
if(res==0||sum>len)//表示文件读取结束
{
write(fd2,buf,res-(sum-len));
break;
}
//写入到目标文件中
write(fd2, buf, res);
}
//关闭文件
close(fd1);
close(fd2);
printf("拷贝成功\n");
}
//创建分支线程
void *task(void *arg)
{
struct Node node=*(struct Node*)arg;
kaobei(node.src,node.dest,node.start,node.len);
pthread_exit(NULL);//退出当前线程
}
/*************主函数****************/
int main(int argc, char*argv[])
{
//判断是否传入两个文件
if(argc != 3)
{
printf("input file error\n");
return -1;
}
int len=lenmain(argv[1],argv[2]);
//定义创建两个线程
pthread_t tid1,tid2;
struct Node node1 ={argv[1],argv[2],0,len/2};
struct Node node2 ={argv[1],argv[2],len/2,len-len/2};
if (pthread_create(&tid1,NULL,task,&node1)!=0)
{
printf("tid1创建失败\n");
return -1;
}
if (pthread_create(&tid2,NULL,task,&node2)!=0)
{
printf("tid2创建失败\n");
return -1;
}
//阻塞等待线程的结束
pthread_join(tid1,NULL);
pthread_join(tid2,NULL);
return 0;
}