想利用多线程，完成复制一个文件的功能，但是，复制后的文件大小与源文件大小不一致。不知道哪儿出错了？

1. import java.io.File;
   
2. import java.io.FileNotFoundException;
   
3. import java.io.IOException;
   
4. import java.io.RandomAccessFile;
   
5. 
   
6. public class RandomAccessFileDownLoad {
   
7. 
   
8.         /**
   
9.          * @param args
   
10.          * @throws FileNotFoundException
    
11.          */
    
12.         public static void main(String[] args) throws FileNotFoundException {
    
13.                 // TODO Auto-generated method stub
    
14.                 File file = new File("a.txt");
    
15.                 final RandomAccessFile reader = new RandomAccessFile(file, "r");
    
16.                 final RandomAccessFile writer = new RandomAccessFile("b.txt", "rw");
    
17.                 long file_length = file.length();
    
18.                 System.out.println(file_length);
    
19.                 final long block = (long) Math.ceil(file_length / 5);
    
20.                 for (int i = 0; i < 5; i++) {
    
21.                         final int temp_i = i;
    
22.                         new Thread(new Runnable() {
    
23. 
    
24.                                 @Override
    
25.                                 public void run() {
    
26.                                         // TODO Auto-generated method stub
    
27.                                         long start = temp_i * block;
    
28.                                         long end = (temp_i + 1) * block - 1;
    
29.                                         try {
    
30.                                                 reader.seek(start);
    
31.                                                 writer.seek(start);
    
32.                                                 System.out.println(Thread.currentThread().getName()
    
33.                                                                 + "     " + start);
    
34.                                                 byte[] bytearr = new byte[1024];
    
35.                                                 int length = 0;
    
36.                                                 while ((length = reader.read(bytearr)) != -1) {
    
37.                                                         writer.write(bytearr, 0, length);
    
38. 
    
39.                                                 }
    
40. 
    
41.                                         } catch (IOException e) {
    
42.                                                 // TODO Auto-generated catch block
    
43.                                                 e.printStackTrace();
    
44.                                         }
    
45. 
    
46.                                 }
    
47. 
    
48.                         }).start();
    
49. 
    
50.                 }
    
51.         }
    
52. 
    
53. }
    

复制代码

看运行结果，各个线程处理的范围应该是每错的

此问题是没有刷新的缘故 write.flush();

SyouRai_Tsk 发表于 2014-4-16 16:35
此问题是没有刷新的缘故 write.flush();

可是我查了一下，它并不能调用flush方法，它自己本身没有flush方法，它的父类和他实现的接口中也没有此方法。

霍振鹏 发表于 2014-4-16 16:45
可是我查了一下，它并不能调用flush方法，它自己本身没有flush方法，它的父类和他实现的接口中也没有此方 ...

我无知了！！！

SyouRai_Tsk 发表于 2014-4-16 17:11
我无知了！！！

呵呵 互相学习呗！

1. /*
   
2. RandomAccessFile 类
   
3. getFilePointer();//获取指针
   
4. skipBytes();//跳过字节
   
5. seek(); 设置指针
   
6. 
   
7. 实现多线程分段输出
   
8. */
   
9. import java.io.*;
   
10. class Demo3
    
11. {
    
12.         public static void main(String[] args)throws Exception
    
13.         {
    
14.                 //读取
    
15.                 RandomAccessFile raf=new RandomAccessFile("g.mp3","rw");
    
16.                 //写入
    
17.                 RandomAccessFile raf1=new RandomAccessFile("gg.mp3","rw");
    
18.                 //三个线程进行分段写入
    
19.                 //seek 设置指针位置 实现分段功能
    
20.                 new Thread(new Thread1(raf,raf1,0)).start();
    
21. 
    
22.                 new Thread(new Thread1(raf,raf1,2097152)).start();
    
23.                
    
24.                 new Thread(new Thread1(raf,raf1,4194304)).start();
    
25.         }
    
26. }
    
27. //多线程
    
28. class Thread1 implements Runnable
    
29. {
    
30.         private RandomAccessFile raf;
    
31.         private RandomAccessFile raf1;
    
32.         private int skip;
    
33.         public Thread1(RandomAccessFile raf,RandomAccessFile raf1,int skip){
    
34.                 this.raf=raf;
    
35.                 this.raf1=raf1;
    
36.                 this.skip=skip;
    
37.         }
    
38.         //run方法
    
39.         public void run(){
    
40.            try
    
41.            {
    
42.                    byte []buf=new byte[1024*1024*2];
    
43.                    int len=0;
    
44.                         len=raf.read(buf);
    
45.                         raf1.write(buf,0,len);
    
46.            }
    
47.            catch (IOException e)
    
48.            {
    
49.                    System.out.println(e.getMessage());
    
50.            }
    
51.            finally
    
52.            {
    
53.                         try
    
54.                         {
    
55.                                 if(raf!=null)
    
56.                                         raf.close();
    
57.                                 if(raf1!=null)
    
58.                                         raf1.close();
    
59.                         }
    
60.                         catch (IOException e)
    
61.                    {
    
62.                            System.out.println(e.getMessage());
    
63.                    }
    
64.            }
    
65.         }
    
66. }
    

复制代码

我这个貌似很彩笔

ノtrack 发表于 2014-4-17 21:13
我这个貌似很彩笔

你这种不能实现具体的自动分配拷贝啊 = ={:3_49:}
是手动分配的具体哪个线程从哪部分拷贝到哪部分。。。