如何获得Files.walk的并行流？

Question

我需要递归地对文件夹中的所有文件进行一些只读处理.我正在使用Files.walk获取文件流,但我注意到api指定walk只返回常规流,而不是并行流.

如何并行处理目录中的所有文件？

Answer 1

您可以通过调用将任何变换Stream为并行.StreamStream::parallel

Stream<Path> stream = Files.walk(startPath).parallel().forEach(...);

Answer 2

我遇到过同样的问题。Files.walk 流似乎不能并行工作。通过调用parallel()处理将流转换为并行流之后，只在一个线程中执行。

Paths正如 Tagir Valeev 所提到的，唯一的解决方案是将收集到的列表转换为列表并在此列表上创建一个并行流。

不工作的解决方案：

Files.walk(Paths.get(System.getProperty("user.dir")))
                    .parallel()
                    .filter(Files::isRegularFile)
                    ...

工作解决方案：

Files.walk(Paths.get(System.getProperty("user.dir")))
                    .collect(Collectors.toList())
                    .parallelStream()
                    .filter(Files::isRegularFile)
                    ...