Java从txt文件中读取特定行并将其线程化

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

public class ReadSpecificLinesThreaded {
    public static void main(String[] args) {
        String filePath = "path/to/your/file.txt";
        List<String> specificLines = new ArrayList<>();

        try (BufferedReader reader = new BufferedReader(new FileReader(filePath))) {
            String line;
            while ((line = reader.readLine()) != null) {
                if (line.contains("specific condition")) {
                    specificLines.add(line);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

        ExecutorService executor = Executors.newFixedThreadPool(10); // 创建线程池，最多同时执行10个线程

        for (String line : specificLines) {
            executor.execute(new ProcessLineTask(line)); // 提交特定行的处理任务给线程池
        }

        executor.shutdown(); // 关闭线程池
    }

    static class ProcessLineTask implements Runnable {
        private String line;

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

        @Override
        public void run() {
            // 处理特定行的逻辑
            // 可以在这里解析数据、存储到数据库、进行计算等
        }
    }
}