Как запустить потоки одновременно и получить доступ к одному и тому же ресурсу в Java

Question

Ниже я написал runnable для запуска через каталог и анализа файлов CSV в нем.Текущий код работает так, что и T1, и T2 читают все файлы в каталоге.как сделать так, чтобы и T1, и T2 работали одновременно, но не имели доступа к одним и тем же файлам для разбора ..

public class ThreadDemo{
    public static void main(String[] args){
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        executorService.execute(new Task());//T1
        executorService.execute(new Task());//T2
        executorService.shutdown();
    }
}

class Task implements Runnable {
    @Override
    public void run() {
        // TODO Auto-generated method stub
        try {
            String line = "";
            String dirName = "/dir/location";
            File[] fileList = new File(dirName).listFiles();
            BufferedReader br = null;
            for (File file :  fileList){
                br = new BufferedReader(new FileReader(file.getName()));
                while ((line = br.readLine()) != null){
                    //parse few vaule
                }
                System.out.println("The file name is this :::: "+file.getName());
            }
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
    }
}

Answer 1

Сначала я бы разделил массив File s на 2 подмассива и дал бы один подмассив для каждой задачи.Как это:

public class ThreadDemo {
    public static void main(String[] args) {
        String dirName = "/dir/location";
        File[] fileList = new File(dirName).listFiles();
        int mid = fileList.length / 2;
        File[] fileListOne = Arrays.copyOfRange(fileList, 0, mid);
        File[] fileListTwo = Arrays.copyOfRange(fileList, mid, fileList.length);
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        executorService.execute(new Task(fileListOne));//T1
        executorService.execute(new Task(fileListTwo));//T2
        executorService.shutdown();
    }
}

class Task implements Runnable {
    private final File[] fileList;

    public Task(File[] fileList) {
        this.fileList = fileList;
    }

    @Override
    public void run() {
        try {
            String line = "";
            for (File file : fileList) {
                try (BufferedReader br = new BufferedReader(new FileReader(file.getName()))) {
                    while ((line = br.readLine()) != null) {
                        //parse few vaule
                    }
                    System.out.println("The file name is this :::: " + file.getName());
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}