温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

怎么在java中使用多线程读取多个文件

发布时间:2021-05-21 16:25:25 来源:亿速云 阅读:907 作者:Leah 栏目:编程语言

怎么在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();
}

Java有哪些集合类

Java中的集合主要分为四类:1、List列表:有序的,可重复的;2、Queue队列:有序,可重复的;3、Set集合:不可重复;4、Map映射:无序,键唯一,值不唯一。

关于怎么在java中使用多线程读取多个文件问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注亿速云行业资讯频道了解更多相关知识。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI