使用 Future 异步读取文件

Question

一般来说，我是线程的新手，所以在这里裸露一下。

我正在阅读以下有关线程和执行程序的页面（1,2）。假设我想异步读取一个大文本文件并返回一个 List 集合以进行迭代。

根据第二个链接：

java.util.concurrent.ExecutorService 接口代表一个 能够执行任务的异步执行机制 在后台。

考虑到这一点，我想出了以下代码示例：

文本文件（我知道文件太小，我们假设它有 100 多个名称）：

Sally Solomon
Dick Solomon
Harry Solomon
Tommy Solomon

代码示例：

String fileName = "C://Users//Nexusfactor//Desktop//read.txt";

ExecutorService executorService = Executors.newSingleThreadExecutor();
Future<List<String>> future = executorService.submit(new Callable<List<String>>(){
    public List<String> call() throws Exception {
        List<String> lstofNames = new ArrayList<String>();
        try (Stream<String> stream = Files.lines(Paths.get(fileName))) 
        {
            lstofNames = stream.collect(Collectors.toList());
        } catch (IOException e) {
            e.printStackTrace();
        }
        return lstofNames;
    }
});
executorService.shutdown();

List<String> display = future.get();

for(String view : display){
    System.out.println(view);
}

这是使用ExecutorService、Future 和submit(Callable) 将文本文件异步读入列表然后迭代的正确方法吗？

Answer 1

问题是主线程立即调用future.get() 并因此阻塞执行程序来处理文件读取。因此，实际上您正在使用 2 个线程，但一次只使用一个（几乎一直如此）。

关于为什么要使用另一个线程/并发的一些示例：

1. 假设有另一个文件（或文件列表）要读取，那么您可以启动一个执行程序（不是单线程）来并行读取多个文件。
2. 假设这是一个巨大的文件，您希望将文件的读取分解为同时运行的多个任务。
3. 假设有一个可以在读取文件的同时完成的 DB 调用。你可以把它放在另一个任务中让执行器来处理，或者让主线程来处理它。
4. 等等。

记住我上面写的都是帮助思考的例子。您需要做的是查看您的需求，然后设计和编写并发代码。在这种特定情况下，不需要并发（由于立即调用future.get()）。

编辑 1（基于您的 cmets）：如果您的目标是了解编写异步任务，那么您列出的人为示例可以满足您的目标。但是，您可以通过思考我提供给您的示例来使其更加现实，或者您可以自己思考一些。