在Java中读取不同线程中的多个文本文件

import java.io.BufferedReader;
import java.io.FileReader;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;

public class MultiThreadFileReader {
    private static final int NUM_THREADS = 5; // 定义线程数量
    private static final String END_OF_FILE = "EOF"; // 定义任务队列结束标志

    private BlockingQueue<String> taskQueue; // 任务队列
    private ExecutorService executor; // 线程池
    private List<String> fileContents; // 存储读取到的文件内容

    public MultiThreadFileReader() {
        taskQueue = new LinkedBlockingQueue<>();
        executor = Executors.newFixedThreadPool(NUM_THREADS);
        fileContents = new ArrayList<>();
    }

    public void readFiles(List<String> fileNames) {
        // 将文件路径添加到任务队列中
        for (String fileName : fileNames) {
            taskQueue.offer(fileName);
        }

        // 启动多个线程读取文件
        for (int i = 0; i < NUM_THREADS; i++) {
            executor.execute(new FileReaderTask());
        }

        // 等待所有线程执行完毕
        executor.shutdown();
        while (!executor.isTerminated()) {
            // 等待线程池中的任务执行完毕
        }

        // 处理读取到的文件内容
        processFileContents();
    }

    private void processFileContents() {
        // 在这里对读取到的文件内容进行合并或处理
        // 这里只是简单地将内容输出到控制台
        for (String content : fileContents) {
            System.out.println(content);
        }
    }

    private class FileReaderTask implements Runnable {
        @Override
        public void run() {
            try {
                String fileName;
                while (!(fileName = taskQueue.take()).equals(END_OF_FILE)) {
                    StringBuilder content = new StringBuilder();
                    try (BufferedReader reader = new BufferedReader(new FileReader(fileName))) {
                        String line;
                        while ((line = reader.readLine()) != null) {
                            content.append(line).append("\n");
                        }
                    }
                    fileContents.add(content.toString());
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args) {
        List<String> fileNames = new ArrayList<>();
        fileNames.add("file1.txt");
        fileNames.add("file2.txt");
        fileNames.add("file3.txt");

        MultiThreadFileReader reader = new MultiThreadFileReader();
        reader.readFiles(fileNames);
    }
}