黑马程序员技术交流社区

标题: RandomAccessFile 多线程下载 [打印本页]
作者: 霍振鹏    时间: 2014-4-16 16:15
标题: RandomAccessFile 多线程下载
本帖最后由 霍振鹏 于 2014-4-16 16:17 编辑

想利用多线程，完成复制一个文件的功能，但是，复制后的文件大小与源文件大小不一致。不知道哪儿出错了？
  1. import java.io.File;
  2. import java.io.FileNotFoundException;
  3. import java.io.IOException;
  4. import java.io.RandomAccessFile;

  6. public class RandomAccessFileDownLoad {

  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() {

  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);

  39.                                                 }

  41.                                         } catch (IOException e) {
  42.                                                 // TODO Auto-generated catch block
  43.                                                 e.printStackTrace();
  44.                                         }

  46.                                 }

  48.                         }).start();

  50.                 }
  51.         }

  53. }
复制代码




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


1234566.png (9.49 KB, 下载次数: 61)

1234566.png
作者: SyouRai_Tsk    时间: 2014-4-16 16:35
此问题是没有刷新的缘故 write.flush();
作者: 霍振鹏    时间: 2014-4-16 16:45
SyouRai_Tsk 发表于 2014-4-16 16:35
此问题是没有刷新的缘故 write.flush();

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

我无知了！！！
作者: 霍振鹏    时间: 2014-4-16 17:15
SyouRai_Tsk 发表于 2014-4-16 17:11
我无知了！！！

呵呵 互相学习呗！
作者: ノtrack    时间: 2014-4-17 21:13
  1. /*
  2. RandomAccessFile 类
  3. getFilePointer();//获取指针
  4. skipBytes();//跳过字节
  5. seek(); 设置指针

  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();

  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. }
复制代码


我这个貌似很彩笔
作者: Kelvinhu    时间: 2014-4-17 21:33
ノtrack 发表于 2014-4-17 21:13
我这个貌似很彩笔

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





欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2