Java代码创建一个用线程池实现多线程读取文件内容的案例

以下是一个使用线程池实现多线程读取文件内容的Java代码示例：

import java.io.*;
import java.util.concurrent.*;

public class FileReadThreadPoolDemo {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(5);
        File file = new File("example.txt");
        try (BufferedReader reader = new BufferedReader(new FileReader(file))) {
            String line;
            while ((line = reader.readLine()) != null) {
                executor.submit(new FileReadTask(line));
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        executor.shutdown();
    }
}

class FileReadTask implements Runnable {
    private String line;

    public FileReadTask(String line) {
        this.line = line;
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + " read: " + line);
    }
}

在上面的代码中，我们使用了线程池来实现多线程读取文件内容。首先，我们创建了一个ExecutorService实例，通过Executors工具类的newFixedThreadPool()方法来创建一个固定大小的线程池。然后，我们创建了一个File实例，指定要读取的文件。

在try-with-resources语句块中，我们创建了一个BufferedReader实例，用于按行读取文件内容。在while循环中，我们逐行读取文件内容，并通过executor.submit()方法提交一个FileReadTask实例，该实例实现了Runnable接口，用于在新的线程中处理读取到的行内容。

最后，我们调用executor.shutdown()方法来关闭线程池。