如何实现异步递归文件夹遍历函数在子函数全部终止后再返回？

你的第二个函数核心问题是处理子目录时未使用await，导致这部分异步操作脱离了当前函数的Promise链，函数会在遍历完当前目录子路径后直接返回，无法等待所有子操作完成。以下是两种符合需求的修正实现：

方案1：同一目录下所有子项（文件+子目录）串行处理 #

该实现保持代码简洁，和你最初的逻辑一致，同时保证所有操作完成后函数才返回：

import fs from 'fs';

async function openPath(path) {
    const stats = fs.statSync(path);
    // 处理文件：执行数据库操作
    if (stats.isFile()) {
        await expensiveOperationWithDB(path);
    } 
    // 处理目录：串行遍历所有子路径
    else if (stats.isDirectory()) {
        const subPaths = fs.readdirSync(path);
        for (const subPath of subPaths) {
            const fullPath = `${path}/${subPath}`;
            // 等待当前子项处理完成后，再处理下一个
            await openPath(fullPath);
        }
    }
}

该方案特性：

• 同一目录下的文件、子目录均按顺序串行处理
• 函数会等待所有子目录递归处理、所有文件数据库操作完成后才返回

方案2：同一目录文件串行，子目录并行处理 #

如果希望提升效率，让同一目录的文件保持串行，但不同子目录可以并行处理：

import fs from 'fs';

async function openPath(path) {
    const stats = fs.statSync(path);
    if (stats.isFile()) {
        await expensiveOperationWithDB(path);
    } else if (stats.isDirectory()) {
        const subPaths = fs.readdirSync(path);
        const dirPromises = [];
        // 遍历子路径：文件串行处理，子目录加入并行队列
        for (const subPath of subPaths) {
            const fullPath = `${path}/${subPath}`;
            const subStats = fs.statSync(fullPath);
            if (subStats.isFile()) {
                await openPath(fullPath);
            } else {
                dirPromises.push(openPath(fullPath));
            }
        }
        // 等待所有并行子目录处理完成
        await Promise.all(dirPromises);
    }
}

该方案特性：

• 同一目录下的文件按顺序逐个处理，满足同步要求
• 不同子目录的处理并行进行，充分利用异步资源
• 函数会等待所有操作完成后才返回

进阶优化：全异步IO版本 #

如果需要避免同步IO阻塞事件循环，可以替换为fs.promises的异步方法：

import fs from 'fs/promises';

async function openPath(path) {
    const stats = await fs.stat(path);
    if (stats.isFile()) {
        await expensiveOperationWithDB(path);
    } else if (stats.isDirectory()) {
        const subPaths = await fs.readdir(path);
        for (const subPath of subPaths) {
            const fullPath = `${path}/${subPath}`;
            await openPath(fullPath);
        }
    }
}

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