如何多线程使用Java Files.walkFileTree与FileVisitor接口？

核心错误原因 #

你的多线程扫描逻辑存在循环变量捕获错误，导致所有线程都在扫描同一个驱动器路径，这才是引发异常的根本原因，和Files.walkFileTree是静态方法无关：

• 你用长度为1的int[] index数组试图绕过Java匿名内部类对effectively final变量的限制，但循环中index[i] = i会在i>=1时直接抛出数组越界异常；
• 即使没有抛出异常，所有线程都会读取index[0]的值，导致所有线程扫描同一个起始路径，引发文件访问冲突和统计异常。

修复后的代码 #

1. 修正线程启动逻辑

private void launchTreeWalkers() {
    ArrayList<Path> effectivelyFinalPath = this.seeds;
    this.twThreads = new Thread[effectivelyFinalPath.size()];

    for (int i = 0; i < effectivelyFinalPath.size(); i++) {
        // 将循环变量转为局部有效final变量，避免捕获问题
        int currentDriveIndex = i;
        this.twThreads[i] = new Thread(() -> {
            try {
                tTreeWalker(effectivelyFinalPath.get(currentDriveIndex));
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        });

        this.twThreads[i].setDaemon(true);
        // 给线程添加序号，方便调试区分
        this.twThreads[i].setName("Tree Walker-" + currentDriveIndex);
        this.twThreads[i].start();
    }

    Display.fmt("%1$,d Tree Walker thread%2$s %3$s been started.", box(this.twThreads.length), Aide.plural(this.twThreads.length), Aide.hasHave(this.twThreads.length));
}

2. 简化路径传递逻辑

tTreeWalker方法无需重复转换路径，直接使用传入的startingPath即可：

/** A walkFileTree thread   */
void tTreeWalker(Path startingPath) throws Exception {
    Files.walkFileTree(startingPath, new FileVisitorImpl());
}

多线程安全性验证 #

• Files.walkFileTree是线程安全的，每个调用都会独立遍历文件树，且你每个线程都创建了独立的FileVisitorImpl实例，不存在共享状态冲突；
• 你使用的LongAdder（计数类）和BlockingQueue（foundFilesQ）本身就是线程安全的，无需额外同步。

可选优化：使用线程池管理线程 #

手动创建线程可以替换为ExecutorService，更便于线程生命周期管理：

private void launchTreeWalkers() {
    int threadCount = seeds.size();
    ExecutorService executor = Executors.newFixedThreadPool(threadCount);
    
    for (int i = 0; i < threadCount; i++) {
        int currentIndex = i;
        executor.submit(() -> {
            try {
                tTreeWalker(seeds.get(currentIndex));
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        });
    }
    
    executor.shutdown(); // 提交所有任务后关闭线程池，等待任务完成
    Display.fmt("%1$,d Tree Walker thread%2$s %3$s been started.", box(threadCount), Aide.plural(threadCount), Aide.hasHave(threadCount));
}

内容的提问来源于stack exchange，提问作者Peter Jerkewitz