基於Java多線程操作文件案例分享

場景描述：某文件夾下有很多文件和文件夾，要求讀取出該文件夾下的所有文件，並將文本打印輸出。

案例分析：假設該文件夾下有10個文件，那麼我們將所有的文件遍歷一遍打印輸出就可以了。但如果有100個, 1000個，10000個，甚至更多呢？這時候或許我們應該考慮使用多線程來解決這個問題喽，分批次讀取文件。

Java實現思路：

（1）List<File> readFiles(String filePath)

（2）subFiles(List<File> fileList, int startIndex, int endIndex)

（3）readFile(File file)

（4）FavThreadUtil(List<File> fileList).run()

干貨代碼：

(一)FavFileUtil.java，上面步驟（1）（2）（3）讀取操作文件用

package com.linuxidc.favthread.util;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.List;

public class FavFileUtil {

public static List<File> getFileList(String filePath){
List<File> fileList = new ArrayList<File>();
File file = new File(filePath);
if(!file.isDirectory()){
System.out.println("文件【" + file.getName() + "】：" + file.getAbsolutePath());
fileList.add(file);
}else{
System.out.println("文件夾【" + file.getName() + "】：" + file.getAbsolutePath());
File[] files = file.listFiles();
for(int i = 0; i < files.length; i++){
if (!files[i].isDirectory()) {
System.out.println("　　文件【" + files[i].getName() + "】：");
fileList.add(files[i]);
} else if (files[i].isDirectory()) {
getFileList(files[i].getAbsolutePath());
}
}

}
return fileList;
}


public static List<File> subFiles(List<File> list, int startIndex, int endIndex){
if(endIndex>list.size()){
return list.subList(startIndex, list.size());
}
return list.subList(startIndex, endIndex);
}


public static void readFile(File file) throws IOException{
//讀取文件
FileInputStream is = new FileInputStream(file);
//獲取文件的字符流
InputStreamReader isr = new InputStreamReader(is);
//緩沖
BufferedReader br = new BufferedReader(isr);
String line = null;
while((line = br.readLine())!=null ){
System.out.println(":::" + line);
}
br.close();
}

}

(二)FavThreadUtil.java，上面步驟（4）操作文件列表用

package com.linuxidc.favthread.util;

import java.io.File;
import java.io.IOException;
import java.util.List;

public class FavThreadUtil implements Runnable {

private List<File> fileList;

public FavThreadUtil(List<File> fileList) {
this.fileList = fileList;
}

@Override
public void run() {
for(File file : fileList){
try {
FavFileUtil.readFile(file);
} catch (IOException e) {
e.printStackTrace();
}
}
}

}

(三)Main.java，Java Main程序運行測試。

package com.linuxidc.favthread.main;

import java.io.File;
import java.util.List;

import com.linuxidc.favthread.util.FavFileUtil;
import com.linuxidc.favthread.util.FavThreadUtil;

public class Main {

public static void main(String[] args) {
List<File> fileList = FavFileUtil.getFileList("D:\\log");
List<File> aList = fileList.subList(0, 10);
List<File> bList = fileList.subList(10, 20);
FavThreadUtil afavThreatUtil = new FavThreadUtil(aList);
FavThreadUtil bfavThreatUtil = new FavThreadUtil(bList);
new Thread(afavThreatUtil, "線程1").start();
new Thread(bfavThreatUtil, "線程2").start();
}

}