общественный класс FileCoper {
частная статическая окончательная строка _ORIGIN_FILE_MODE = "r";
частная статическая конечная строка _TARGET_FILE_MODE = "rw";
частный статический долгое время1 = 0l;
частная строка originFileName;
частная строка targetFileName;
частный RandomAccessFile originFile;
частный RandomAccessFile targetFile;
частный int threadCount;
частный статический int totalThreadCount = 0;
частный статический int выполненныйCount = 0;
общественный FileCoper() {
this.threadCount = 1;
TotalThreadCount = this.threadCount;
}
public FileCoper (String originFile, String targetFile) {
пытаться {
this.originFileName = исходный файл;
this.targetFileName = targetFile;
this.originFile = новый RandomAccessFile((originFile), FileCoper._ORIGIN_FILE_MODE);
this.targetFile = новый RandomAccessFile((targetFile), FileCoper._TARGET_FILE_MODE);
this.threadCount = 1;
TotalThreadCount = this.threadCount;
} catch (FileNotFoundException e) {
е.printStackTrace();
}
}
public FileCoper (String originFile, String targetFile, int threadCount) {
пытаться {
this.originFileName = исходный файл;
this.targetFileName = targetFile;
this.originFile = новый RandomAccessFile((originFile), FileCoper._ORIGIN_FILE_MODE);
this.targetFile = новый RandomAccessFile((targetFile), FileCoper._TARGET_FILE_MODE);
this.threadCount = 1;
TotalThreadCount = this.threadCount;
} catch (FileNotFoundException e) {
е.printStackTrace();
}
}
public void init(String originFile, String targetFile) выдает исключение {
this.originFileName = исходный файл;
this.targetFileName = targetFile;
this.originFile = новый RandomAccessFile((originFile), FileCoper._ORIGIN_FILE_MODE);
this.targetFile = новый RandomAccessFile((targetFile), FileCoper._TARGET_FILE_MODE);
this.threadCount = 1;
TotalThreadCount = this.threadCount;
}
public void init (String originFile, String targetFile, int threadCount) выдает исключение {
this.originFileName = исходный файл;
this.targetFileName = targetFile;
this.originFile = новый RandomAccessFile((originFile), FileCoper._ORIGIN_FILE_MODE);
this.targetFile = новый RandomAccessFile((targetFile), FileCoper._TARGET_FILE_MODE);
this.threadCount = threadCount;
TotalThreadCount = this.threadCount;
}
public void init(RandomAccessFile originFile, RandomAccessFile targetFile) выдает исключение {
this.originFile = originFile;
this.targetFile = targetFile;
this.threadCount = 1;
TotalThreadCount = this.threadCount;
}
public void init(RandomAccessFile originFile, RandomAccessFile targetFile, int threadCount) выдает исключение {
this.originFile = originFile;
this.targetFile = targetFile;
this.threadCount = threadCount;
TotalThreadCount = this.threadCount;
}
общедоступная статическая синхронизированная недействительная отделка () {
FileCoper.executedCount++;
System.out.println("总线程【" + FileCoper.totalThreadCount + "】,已经完成【" + FileCoper.executedCount + "】个线程的复制！！！");
если (FileCoper.totalThreadCount == FileCoper.executedCount){
долгое время2 = System.currentTimeMillis();
System.out.println("花费时长:"+(time2-time1));
System.out.println("所有【" + FileCoper.totalThreadCount + "】线程复制完成！！！");
}
}
public void start() выдает исключение {
если (this.originFile.length() == 0)
возвращаться;
если (this.threadCount == 0)
this.threadCount = 1;
// 设置目标文件大小
this.targetFile.setLength(this.originFile.length());
this.targetFile.seek(0);
this.originFile.seek(0);
время1 = System.currentTimeMillis();
System.out.println(this.originFile.length());
// 把文件分块，每一块有一对值:当前块在文件中的起始位置和结束位置
long[][] разбивается = новый long[this.threadCount][2];
длинный originFileLength = this.originFile.length();
интервал startPos = 0;
for (int i = 0; i < this.threadCount; i++) {
разбивает[я][0] = 0;
разбивает[i][1] = 0;
если (я == 0) {
разбивает[я][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;
} еще {
// 注意:此处不能加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]);
Копер fc = новый Копер("thread-" + i);
fc.init(this.originFile, this.targetFile, Splits[i][0], Splits[i][1]);
fc.setOriginFileName(this.originFileName);
fc.setTargetFileName(this.targetFileName);
ФК.старт();
}
}
public void startNew() выдает исключение {
если (this.originFile.length() == 0)
возвращаться;
// 设置目标文件大小
this.targetFile.setLength(this.originFile.length());
this.targetFile.seek(0);
this.originFile.seek(0);
длинный startPosition;
длинная конечная позиция;
длинный блок = this.originFile.length() / 1029;
если (блок <= 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);
если (я == (this.threadCount - 1))
endPosition = this.originFile.length();
Копер fc = новый Копер("thread-" + i);
fc.init(this.originFile, this.targetFile, startPosition, endPosition);
fc.setOriginFileName(this.originFileName);
fc.setTargetFileName(this.targetFileName);
ФК.старт();
}
}
частный класс Копер расширяет поток {
частная строка originFileName;
частная строка targetFileName;
частный RandomAccessFile originFile;
частный RandomAccessFile targetFile;
частная строка threadId;
частная длинная стартовая позиция;
частная длинная позиция конца;
частный длинный блокЕмкость;
public void setOriginFileName (String originFileName) {
this.originFileName = originFileName;
}
public void setTargetFileName (String targetFileName) {
this.targetFileName = targetFileName;
}
общественный Копер (String threadId) {
this.threadId = threadId;
}
public void init(RandomAccessFile originFile, RandomAccessFile targetFile, long startPosition, long endPosition) выдает исключение {
this.originFile = originFile;
this.targetFile = targetFile;
this.startPosition = startPosition;
this.endPosition = endPosition;
this.blockCapacity = this.endPosition - this.startPosition;
}
общественный недействительный запуск () {
// System.out.println(this.threadId + " 启动，开始复制文件【" +
// this.originFileName + "】中的文件块【" + this.startPosition + "," +
// this.endPosition + "】到目标文件【" + this.targetFileName + "】中...");
синхронизировано (this.originFile) {
пытаться {
// 记录当前拷贝的字节数
интервал copyCount = 0;
// 数据拷贝的启示偏移量
длинный offSet = this.startPosition;
байт[] b = новый байт[16 * 1024 * 1024];
// 动态设置一次读取的字节数缓冲
длинный размер блока = 0;
в то время как (copyCount <this.blockCapacity) {
this.originFile.seek(offSet);
if (this.blockCapacity - copyCount > 16 * 1024 * 1024)
размер блока = 16*1024*1024;
еще
blockSize = this.blockCapacity - copyCount;
if (blockSize > this.blockCapacity - copyCount)
blockSize = this.blockCapacity - copyCount;
int count = this.originFile.read(b, 0, (int)blockSize);
синхронизировано (this.targetFile) {
пытаться {
если (copyCount == 0)
this.targetFile.seek(offSet);
еще
this.targetFile.seek(offSet + 1);
this.targetFile.write(b, 0, count);
} catch (IOException e) {
е.printStackTrace();
}
}
// 增加拷贝的字节数
copyCount += количество;
// 拷贝其实【偏移量下移
OffSet += счетчик;
}
} catch (IOException e) {
е.printStackTrace();
}
}
// System.out.println(this.threadId + " 复制文件【" + this.originFileName
// + "】中的文件块【" + this.startPosition + "," + this.endPosition +
// "】到目标文件【" + this.targetFileName + "】完成!");
// 通知主线程，当前线程完成复制工作
FileCoper.finish();
}
}
public static void main(String[] args) выдает исключение {
FileCoper FC = новый 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 = новый BufferedReader (новый InputStreamReader (System.in));
// 文件来源
Строка OriginFile;
// 文件目标
Строка целевой файл;
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();
долгое время1 = System.currentTimeMillis();
ФК.старт();
долгое время2 = System.currentTimeMillis();
System.out.println(время2-время1);
}
}