package com.xtd.file.gash.general;

import java.io.*;
import java.util.LinkedList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ReadCSVMove {

    private static FileReader fileReader = null;
    private static BufferedReader bufferedReader = null;
    private static List<String> list = new LinkedList<String>();    //247576
    private static final String filePath = "C:\\Users\\com\\Desktop\\测试数据\\EEMMSI.csv";
    private static final String basePath = "E:\\HistoryData\\ArcticOceanData\\ArcticOceanData\\finish\\201707\\";
    private static final String movePath = "C:\\Users\\com\\Desktop\\测试数据\\其他\\";
    private static final ExecutorService fixedThreadPool = Executors.newFixedThreadPool(60);

    public static void main(String[] args) {
        readCSV(filePath);
        System.out.println(list.size());
        forDir(basePath,movePath);
    }

    /**
     * 遍历文件目录
     * @param basePath
     * @param movePath
     */
    private static void forDir(String basePath,String movePath){
        for(int i=1;i<list.size();i++){
            int finalI = i;
            // 每个线程处理一个 MMSI
            fixedThreadPool.execute(() -> {
                String sourcePath = basePath + list.get(finalI) + ".csv";
                String targePath = movePath + list.get(finalI) + ".csv";
                System.out.println("sourcePath\t" + sourcePath);
                System.out.println("targePath\t" + targePath);
                new File(sourcePath).renameTo(new File(targePath));
            });
        }
        // 执行完毕，关闭线程池
        fixedThreadPool.shutdown();
    }

    /**
     * 读取CSV文件，存入list
     * @param path
     */
    private static void readCSV(String path){
        try {
            fileReader = new FileReader(path);
            bufferedReader = new BufferedReader(fileReader);
            String str;
            while ( null != (str = bufferedReader.readLine()) ) {
                list.add(str);
            }
            bufferedReader.close();
            fileReader.close();
        }
        catch (IOException e) {
            e.printStackTrace();
        }
    }
}

?

?