java 8 lambda递归失败

Question

我正在尝试使用 lambda 递归遍历目录和每个子目录，同时将每个子目录推送到新线程。

问题是它正在通过顶级目录和 所有第一轮子目录，但拒绝深入第一级子目录中的任何子目录。

我不明白为什么它适用于第一级递归但不适用于第二级。嵌套线程和/或 lambda 函数的次数是否有限制？

下面是我的代码的相关部分：

public class Main
{
    public static ExecutorService localExecutor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());

    public static void getFileNames(final Path dir)
    {
        try (DirectoryStream<Path> stream = Files.newDirectoryStream(dir))
        {
            for (Path path : stream) {
                System.out.println(path);

                if (path.toFile().isDirectory()) {
                    Runnable subDir = () -> getFileNames(path);

                    localExecutor.submit(subDir);
                }
            }
        }
        catch (IOException e)
        {
            e.printStackTrace();
        }
    }

    public static void main(String... args)
    {
        getFileNames(
            FileSystems.getDefault().getPath("C:\\A")
        );
         //
     //I wait for it to finish all tasks in another method that contains the below

        functions.localExecutor.shutdown();
        try {
        functions.localExecutor.awaitTermination(Long.MAX_VALUE, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            System.out.print("Exception: the following error occured: ");
            System.out.println(e.toString());
            MainLogic.log.add("Exception: the following error occured: " +     e.toString());
        }

    }

}

Answer 1

问题是你的程序没有等待那些子任务被执行。它只是立即返回。所以只打印出第一级目录，因为那些 println 不依赖于任何可运行的子目录来执行。

通常可以调用ExecutorService 的shutdown 和awaitTermination，等待任何挂起的任务运行。但是，这在您的情况下不起作用，因为直到稍后执行其父目录的任务时才会添加更深的目录级别的相应任务。