java多线程复制文件

package com.test;    import java.io.FileNotFoundException;  import java.io.IOException;  import java.io.RandomAccessFile;    public class FileCoper {   private static final String _ORIGIN_FILE_MODE = "r";          private static final String _TARGET_FILE_MODE = "rw";      private static long time1 = 0l;    private String originFileName;          private String targetFileName;          private RandomAccessFile originFile;          private RandomAccessFile targetFile;          private int threadCount;          private static int totalThreadCount = 0;        private static int executedCount = 0;      public FileCoper() {     this.threadCount = 1;     totalThreadCount = this.threadCount;    }      public FileCoper(String originFile, String targetFile) {     try {      this.originFileName = originFile;      this.targetFileName = targetFile;      this.originFile = new RandomAccessFile((originFile), FileCoper._ORIGIN_FILE_MODE);      this.targetFile = new RandomAccessFile((targetFile), FileCoper._TARGET_FILE_MODE);      this.threadCount = 1;      totalThreadCount = this.threadCount;     } catch (FileNotFoundException e) {      e.printStackTrace();     }    }      public FileCoper(String originFile, String targetFile, int threadCount) {     try {      this.originFileName = originFile;      this.targetFileName = targetFile;      this.originFile = new RandomAccessFile((originFile), FileCoper._ORIGIN_FILE_MODE);      this.targetFile = new RandomAccessFile((targetFile), FileCoper._TARGET_FILE_MODE);      this.threadCount = 1;      totalThreadCount = this.threadCount;     } catch (FileNotFoundException e) {      e.printStackTrace();     }    }          public void init(String originFile, String targetFile) throws Exception {     this.originFileName = originFile;     this.targetFileName = targetFile;     this.originFile = new RandomAccessFile((originFile), FileCoper._ORIGIN_FILE_MODE);     this.targetFile = new RandomAccessFile((targetFile), FileCoper._TARGET_FILE_MODE);     this.threadCount = 1;     totalThreadCount = this.threadCount;    }          public void init(String originFile, String targetFile, int threadCount) throws Exception {     this.originFileName = originFile;     this.targetFileName = targetFile;     this.originFile = new RandomAccessFile((originFile), FileCoper._ORIGIN_FILE_MODE);     this.targetFile = new RandomAccessFile((targetFile), FileCoper._TARGET_FILE_MODE);     this.threadCount = threadCount;     totalThreadCount = this.threadCount;    }          public void init(RandomAccessFile originFile, RandomAccessFile targetFile) throws Exception {     this.originFile = originFile;     this.targetFile = targetFile;     this.threadCount = 1;     totalThreadCount = this.threadCount;    }          public void init(RandomAccessFile originFile, RandomAccessFile targetFile, int threadCount) throws Exception {     this.originFile = originFile;     this.targetFile = targetFile;     this.threadCount = threadCount;     totalThreadCount = this.threadCount;    }          public static synchronized void finish() {     FileCoper.executedCount ++;          System.out.println("总线程【" + FileCoper.totalThreadCount + "】,已经完成【" + FileCoper.executedCount + "】个线程的复制！！！");     if (FileCoper.totalThreadCount == FileCoper.executedCount){      long time2 = System.currentTimeMillis();      System.out.println("花费时长："+(time2-time1));       System.out.println("所有【" + FileCoper.totalThreadCount + "】线程复制完成！！！");     }    }          public void start() throws Exception {     if (this.originFile.length() == 0)      return;     if (this.threadCount == 0)      this.threadCount = 1;     // 设置目标文件大小     this.targetFile.setLength(this.originFile.length());     this.targetFile.seek(0);     this.originFile.seek(0);        time1 = System.currentTimeMillis();     System.out.println(this.originFile.length());     // 把文件分块，每一块有一对值：当前块在文件中的起始位置和结束位置     long[][] splits = new long[this.threadCount][2];     long originFileLength = this.originFile.length();     int startPos = 0;     for (int i = 0; i < this.threadCount; i++) {      splits[i][0] = 0;      splits[i][1] = 0;      if (i == 0) {       splits[i][0] = 0;       splits[i][1] = originFileLength / this.threadCount;        } else if (i == this.threadCount - 1) {       // 注意：此处不能加1，如果加1，线程多文件就会出现乱码       // splits[i][0] = startPos + 1;       splits[i][0] = startPos;       splits[i][1] = originFileLength;      } else {       // 注意：此处不能加1，如果加1，线程多文件就会出现乱码       // splits[i][0] = startPos + 1;       splits[i][0] = startPos;       splits[i][1] = startPos + originFileLength / this.threadCount;      }      startPos += originFileLength / this.threadCount;      // System.out.println(splits[i][0] + " " + splits[i][1]);        Coper fc = new Coper("thread-" + i);      fc.init(this.originFile, this.targetFile, splits[i][0], splits[i][1]);      fc.setOriginFileName(this.originFileName);      fc.setTargetFileName(this.targetFileName);      fc.start();     }    }          public void startNew() throws Exception {     if (this.originFile.length() == 0)      return;     // 设置目标文件大小     this.targetFile.setLength(this.originFile.length());     this.targetFile.seek(0);     this.originFile.seek(0);       long startPosition;     long endPosition;     long block = this.originFile.length() / 1029;       if (block <= 1)      this.threadCount = 1;       for (int i = 0; i < this.threadCount; i++) {      // 定义每次转移的长度      startPosition = i * 1029 * (block / this.threadCount);      endPosition = (i + 1) * 1029 * (block / this.threadCount);      if (i == (this.threadCount - 1))       endPosition = this.originFile.length();      Coper fc = new Coper("thread-" + i);      fc.init(this.originFile, this.targetFile, startPosition, endPosition);      fc.setOriginFileName(this.originFileName);      fc.setTargetFileName(this.targetFileName);      fc.start();       }    }      private class Coper extends Thread {            private String originFileName;            private String targetFileName;          private RandomAccessFile originFile;            private RandomAccessFile targetFile;            private String threadId;            private long startPosition;            private long endPosition;            private long blockCapacity;            public void setOriginFileName(String originFileName) {      this.originFileName = originFileName;     }            public void setTargetFileName(String targetFileName) {      this.targetFileName = targetFileName;     }       public Coper(String threadId) {      this.threadId = threadId;     }            public void init(RandomAccessFile originFile, RandomAccessFile targetFile, long startPosition, long endPosition) throws Exception {      this.originFile = originFile;      this.targetFile = targetFile;      this.startPosition = startPosition;      this.endPosition = endPosition;      this.blockCapacity = this.endPosition - this.startPosition;     }       public void run() {      // System.out.println(this.threadId + " 启动，开始复制文件【" +      // this.originFileName + "】中的文件块【" + this.startPosition + "," +      // this.endPosition + "】到目标文件【" + this.targetFileName + "】中...");      synchronized (this.originFile) {       try {        // 记录当前拷贝的字节数        int copyCount = 0;        // 数据拷贝的启示偏移量        long offSet = this.startPosition;        byte[] b = new byte[16 * 1024 * 1024];        // 动态设置一次读取的字节数缓冲        long blockSize = 0;        while (copyCount < this.blockCapacity) {         this.originFile.seek(offSet);         if (this.blockCapacity - copyCount > 16 * 1024 * 1024)          blockSize = 16 * 1024 * 1024;         else          blockSize = this.blockCapacity - copyCount;         if (blockSize > this.blockCapacity - copyCount)          blockSize = this.blockCapacity - copyCount;         int count = this.originFile.read(b, 0, (int) blockSize);         synchronized (this.targetFile) {          try {           if (copyCount == 0)            this.targetFile.seek(offSet);           else            this.targetFile.seek(offSet + 1);             this.targetFile.write(b, 0, count);          } catch (IOException e) {           e.printStackTrace();          }         }         // 增加拷贝的字节数         copyCount += count;         // 拷贝其实【偏移量下移         offSet += count;        }       } catch (IOException e) {        e.printStackTrace();       }      }      // System.out.println(this.threadId + " 复制文件【" + this.originFileName      // + "】中的文件块【" + this.startPosition + "," + this.endPosition +      // "】到目标文件【" + this.targetFileName + "】完成!");        // 通知主线程，当前线程完成复制工作      FileCoper.finish();     }      }      public static void main(String[] args) throws Exception {     FileCoper fc = new FileCoper();     fc.init("e:/InitialData_zhihuan.sql", "e:/InitialData_zhihuan2.sql", 30);     //fc.init("d:/ValueAdd_11.txt", "d:/ValueAdd_111.txt", 100);     // fc.init("D:\tools\music\做你的爱人.mp3", "d:/做你的爱人_5.mp3", 10);     //fc.init("E:\电影\最黑暗侵袭.rmvb", "d:/最黑暗侵袭_1.rmvb", 100);         /* // 读入键盘输入     BufferedReader br = new BufferedReader(new InputStreamReader(System.in));     // 文件来源     String originFile;     // 文件目标     String targetFile;     System.out.println("【源文件、目标文件、线程数】");     System.out.print("要复制的源文件：");     originFile = br.readLine();     System.out.print("文件复制到目标文件：");     targetFile = br.readLine();     System.out.print("切分线程数：");     int threadCount = Integer.parseInt(br.readLine());     fc.init(originFile, targetFile, threadCount);*/     // fc.startNew();     long time1 = System.currentTimeMillis();     fc.start();     long time2 = System.currentTimeMillis();     System.out.println(time2-time1);    }  }