java多线程读取多个文件的方法

本文实例为大家分享了java多线程读取多个文件的具体代码，供大家参考，具体内容如下

工具类代码如下：

import java.io.*;
import java.util.List;
import java.util.concurrent.CountDownLatch;

/**
* 多线程读取多个文件
*/
public class FileThread extends Thread{

private final CountDownLatch countDownLatch = new CountDownLatch(10);
private int fileIndex;
private List<String> filelist;
private String filepath = "D:\\LocalFtpServer\\data20181229\\";
private String movepath = "D:\\LocalFtpServer\\data20181229_01\\";

public int getFileIndex() {
 return fileIndex;
}

public void setFileIndex(int fileIndex) {
 this.fileIndex = fileIndex;
}

public List<String> getFilelist() {
 return filelist;
}

public void setFilelist(List<String> filelist) {
 this.filelist = filelist;
}

@Override
public void run() {

for (int i = 0; i < filelist.size(); i++) {
  if (i ％ 10 == fileIndex) {
   //读取文件
   File readfile = new File(filepath + filelist.get(i));
   InputStreamReader isr = null;
   try {
    isr = new InputStreamReader(new FileInputStream(readfile), "UTF-8");
    BufferedReader reader = new BufferedReader(isr);
    String line = null;
    // 一次读入一行，直到读入null为文件结束
    while ((line = reader.readLine()) != null) {
     System.out.println(line );
    }
    reader.close();
    isr.close();
   } catch (UnsupportedEncodingException e) {
    e.printStackTrace();
   } catch (IOException e) {
    e.printStackTrace();
   }
   //读取完后， 移动文件位置
   readfile.renameTo(new File(movepath + readfile.getName()));
  }
 }
 countDownLatch.countDown();
}
}

调用测试：

public static void main(String[] args) throws IOException {
String filepath = "D:\\LocalFtpServer\\data20181229\\";
File file = new File(filepath);
//读取目录下所有文件
String[] filelist = file.list();
List<String> fList=new ArrayList<String>();

for (int i = 0; i < filelist.length; i++) {
if (filelist[i].startsWith("data") && filelist[i].endsWith(".txt")) {
 fList.add(filelist[i]);
}
}
for(int i=0;i<30;i++){
FileThread fileThread=new FileThread();
fileThread.setFileIndex(i);
fileThread.setFilelist(fList);
fileThread.start();
}
countDownLatch.await();
}

来源：https://blog.csdn.net/HoneyYHQ9988/article/details/85601628