package testThread.file_threading;

import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.RandomAccessFile;

public class ThreadFileCopy extends Thread {
? ? private String srcFileStr;//源文件的路徑
? ? private String desFileStr;//目標(biāo)文件的路徑 ,des --> destination目的地
? ? private long skipLen;//跳過(guò)多少個(gè)字節(jié)開(kāi)始讀/寫(xiě)
? ? private long workload;//總共要讀/寫(xiě)多少個(gè)字節(jié)
? ? private final int IO_UNIT = 1024;//每次讀寫(xiě)的基本單位（1024個(gè)字節(jié)）

? ? public ThreadFileCopy(String srcFileStr, String desFileStr, long skipLen, long workload) {
? ? ? ? this.srcFileStr = srcFileStr;
? ? ? ? this.desFileStr = desFileStr;
? ? ? ? this.skipLen = skipLen;
? ? ? ? this.workload = workload;
? ? }
? ? public void run(){
? ? ? ? FileInputStream fis = null;
? ? ? ? BufferedInputStream bis = null;//利用高級(jí)緩沖流，加快讀的速度
? ? ? ? RandomAccessFile raf = null;
? ? ? ? try {
? ? ? ? ? ? fis = new FileInputStream(srcFileStr);
? ? ? ? ? ? bis = new BufferedInputStream(fis);
? ? ? ? ? ? raf = new RandomAccessFile(desFileStr,"rw");
? ? ? ? ? ? bis.skip(this.skipLen);//跳過(guò)一部分字節(jié)開(kāi)始讀
? ? ? ? ? ? raf.seek(this.skipLen);//跳過(guò)一部分字節(jié)開(kāi)始寫(xiě)
? ? ? ? ? ? byte[] bytes = new byte[IO_UNIT];
? ? ? ? ? ? //根據(jù)總共需要復(fù)制的字節(jié)數(shù) 和 讀寫(xiě)的基本單元 計(jì)算出一共需要讀寫(xiě)的次數(shù)，利用讀寫(xiě)次數(shù)控制循環(huán)
? ? ? ? ? ? long io_num = this.workload/IO_UNIT + 1;//因?yàn)閣orkload/1024 很可能不能整除，會(huì)有余數(shù)
? ? ? ? ? ? if(this.workload % IO_UNIT == 0)
? ? ? ? ? ? ? ? io_num--;//如果碰巧整除，讀寫(xiě)次數(shù)減一
? ? ? ? ? ? //count表示讀取的有效字節(jié)數(shù)，雖然count不參與控制循環(huán)結(jié)束，
? ? ? ? ? ? // 但是它能有效避免最后一次讀取出的byte數(shù)組中有大量空字節(jié)寫(xiě)入到文件中，導(dǎo)致復(fù)制出的文件稍稍變大
? ? ? ? ? ? int count = bis.read(bytes);
? ? ? ? ? ? while (io_num != 0){
? ? ? ? ? ? ? ? raf.write(bytes,0,count);
? ? ? ? ? ? ? ? count = bis.read(bytes,0,count);//重新計(jì)算count的值
? ? ? ? ? ? ? ? io_num--;
? ? ? ? ? ? }
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }finally {
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? if (fis != null)
? ? ? ? ? ? ? ? ? ? fis.close();
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? if (bis != null)
? ? ? ? ? ? ? ? ? ? bis.close();
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? if (raf != null)
? ? ? ? ? ? ? ? ? ? raf.close();
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? }
? ? }
}

package testThread.file_threading;

import java.io.File;

public class TestMain {
? ? public static void main(String[] args) {
? ? ? ? int thread_num = 5;//創(chuàng)建5個(gè)線程讀寫(xiě)
? ? ? ? String srcFileStr = "E:\\test\\123.flv";
? ? ? ? String desFileStr = "E:\\test\\thread.flv";
? ? ? ? File srcFile = new File(srcFileStr);
? ? ? ? long workload = srcFile.length()/thread_num;//總共要讀/寫(xiě)多少個(gè)字節(jié)
? ? ? ? //用一個(gè)數(shù)組來(lái)存儲(chǔ)每個(gè)線程跳過(guò)的字節(jié)數(shù)
? ? ? ? long[] skipLenArr = new long[thread_num];
? ? ? ? for(int i = 0;i<skipLenArr.length;i++){
? ? ? ? ? ? skipLenArr[i] = i*workload;
? ? ? ? }
? ? ? ? //用一個(gè)數(shù)組來(lái)存儲(chǔ)所有的線程
? ? ? ? ThreadFileCopy[] tfcs = new ThreadFileCopy[thread_num];
? ? ? ? //初始化所有線程
? ? ? ? for(int i = 0;i<tfcs.length;i++){
? ? ? ? ? ? tfcs[i] = new ThreadFileCopy(srcFileStr,desFileStr,skipLenArr[i],workload);
? ? ? ? }
? ? ? ? //讓所有線程進(jìn)入就緒狀態(tài)
? ? ? ? for(int i = 0;i<tfcs.length;i++){
? ? ? ? ? ? tfcs[i].start();
? ? ? ? }
? ? ? ? System.out.println("復(fù)制完畢！");
? ? }
}