中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

怎么在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

武胜县| 白水县| 上饶县| 阿合奇县| 石景山区| 新野县| 唐河县| 黔江区| 临桂县| 宁化县| 政和县| 固安县| 晴隆县| 大港区| 深圳市| 高邮市| 石楼县| 镇康县| 司法| 邵阳县| 宁城县| 巴中市| 依安县| 旬邑县| 黄浦区| 永仁县| 肃宁县| 青岛市| 得荣县| 屯留县| 密山市| 衡阳市| 信宜市| 团风县| 梓潼县| 阿合奇县| 娄烦县| 临汾市| 娱乐| 阿勒泰市| 云南省|