学习IO的时候,我们都曾经利用文件IO函数,标准IO函数都实现了对文件的拷贝,
对某一个文件进行拷贝时,我们可以考虑一下几种方式:
a.单进程拷贝:
假设某一文件需要拷贝100字节,每一个时间片可以完成拷贝20个字节工作量,则需要被分配5个时间片才可以完成任务,但问题是这些个时间片并不是被连续分配的,我们并不知道
到经过多少时间片才会有下一个能分配给该进程的时间片,为了解决这个问题,我们有了第二种方法。
b.多进程拷贝(单核单CPU):
通过切换进程,随着进程数的增加,当前程序获得时间片所需要的时间也就更少。
c.多进程拷贝(多核并发处理)
我们要实现的是第二个方法,代码如下:
1 #include<stdio.h> 2 #include<stdlib.h> 3 #include<unistd.h> 4 #include<fcntl.h> 5 #include<string.h> 6 #include<sys/types.h> 7 #include<sys/stat.h> 8 #include<sys/wait.h> 9 int cutting(char *src,int prono) 10 { 11 int fd,filesize; 12 if((fd=open(src,O_RDONLY))==-1) 13 { 14 perror("cutting open failed"); 15 return -1; 16 } 17 if((filesize=lseek(fd,0,SEEK_END))==-1) 18 { 19 perror("filesize failed"); 20 close(fd); 21 return -1; 22 } 23 int blocksize; 24 if(filesize%prono==0) 25 { 26 blocksize=filesize/prono; 27 } 28 else 29 { 30 blocksize=filesize/prono+1; 31 } 32 close(fd); 33 //printf("%d",blocksize); 34 return blocksize; 35 36 } 37 int copy(char *src,char *des,int pos,int blocksize) 38 { 39 if(access(src,F_OK)==-1) 40 { 41 perror("acess failed"); 42 } 43 int fd1,fd2; 44 char buf[blocksize]; 45 fd1=open(src,O_RDONLY); 46 fd2=open(des,O_WRONLY|O_CREAT,0664); 47 lseek(fd1,pos,SEEK_SET); 48 lseek(fd2,pos,SEEK_SET); 49 50 51 int len=read(fd1,buf,sizeof(buf)); 52 write(fd2,buf,len); 53 close(fd1); 54 close(fd2); 55 return 1; 56 } 57 int create(char *src,char *des,int blocksize,int prono) 58 { 59 int i; 60 pid_t pid; 61 int pos=0; 62 for(i=0;i<prono;i++) 63 { 64 pid=fork(); 65 if(pid>0) 66 { 67 pos+=blocksize; 68 69 //printf("当前读取位置为:%d,每次所读文件大小:%d,当前进程为%d ",pos,blocksize,getpid()); 70 71 } 72 73 else if(pid==0) 74 { 75 copy(src,des,pos,blocksize); 76 77 printf("当前读取位置为:%d,每次所读文件大小:%d,当前进程为%d ",pos,blocksize,getpid()); 78 break; 79 } 80 81 } 82 return 1; 83 } 84 int main(int argc,char **argv) 85 { 86 int prono; 87 int blocksize; 88 if(argc<3) 89 { 90 printf("the canshu you have chuan are too less "); 91 } 92 if(argv[3]!=0) 93 { 94 prono=atoi(argv[3]); 95 if(prono<=0||prono>=100) 96 { 97 printf("the num of the process you give cant not less than 0 or more than 100 "); 98 } 99 100 } 101 else prono=5; 102 blocksize=cutting (argv[1],prono); 103 create(argv[1],argv[2],blocksize,prono); 104 105 return 0; 106 }