异步函数中for循环未执行问题求助

核心问题 #

• 混用回调与async/await：回调版fs.readdir不返回Promise，await对它完全无效，外层函数会直接执行完毕返回undefined，根本等不到回调里的逻辑执行。
• 无效的await使用：files.filter、JSON.parse都是同步操作，不需要加await，多余的await反而会引发逻辑混乱。
• 返回值无法传递：回调函数里的return results不会传递给外层的MyReadFilesAsync函数，外层函数没有任何有效返回语句。
• 逻辑错误：else分支中results.push(result_i)写在if判断外，会导致未定义的变量被push，且存在重复添加的问题。

修复方案 #

不用fs.promises的话，可通过util.promisify把回调式的fs方法转为Promise，这样既能用async/await语法，又能通过Promise.all实现并行处理，避免服务器冻结（异步并行操作不会阻塞事件循环）。

修复后的代码 #

const fs = require('fs');
const path = require('path');
const { promisify } = require('util');

// 将回调式fs方法转为Promise
const readdir = promisify(fs.readdir);
const readFile = promisify(fs.readFile);

async function MyReadFilesAsync(directoryPath, inputFileName, inputSearchTerm) {
    try {
        // 读取目录，使用promisify后的方法支持await
        const files = await readdir(directoryPath);
        
        // 过滤目标文件，同步操作无需await
        const postFiles = files.filter(filename => filename === inputFileName);
        
        const searchTerm = inputSearchTerm.toLowerCase();
        
        // 并行处理所有文件，提升效率
        const results = await Promise.all(postFiles.map(async (filename) => {
            const filePath = path.join(directoryPath, filename);
            const fileContent = await readFile(filePath, 'utf8');
            
            // JSON.parse为同步操作，无需await
            const sampleData = JSON.parse(fileContent);
            
            // 根据搜索条件筛选结果
            if (searchTerm === "") {
                return { fileContent };
            } else {
                const titleMatch = sampleData[0].title.toLowerCase().includes(searchTerm);
                const messageMatch = sampleData[0].message.toLowerCase().includes(searchTerm);
                if (titleMatch || messageMatch) {
                    return { fileContent };
                }
                // 不匹配时返回undefined，后续过滤掉
                return undefined;
            }
        }));
        
        // 过滤无效结果，返回有效数据
        return results.filter(item => item !== undefined);
        
    } catch (error) {
        console.error('Error reading files:', error);
        // 抛出错误让调用者处理
        throw error;
    }
}

关键改进说明 #

• 用util.promisify转换fs方法，既避开fs.promises，又能利用async/await的异步优势。
• 通过Promise.all并行处理文件，比串行循环效率更高，且异步操作不会阻塞事件循环，避免服务器冻结。
• 移除了所有无效的await调用，修正了重复添加结果的逻辑错误。
• 外层函数直接返回处理后的结果，调用者可通过await MyReadFilesAsync(...)获取返回值。
• 统一错误处理逻辑，外层try/catch可捕获所有异步错误并向外抛出，便于调用者处理异常。

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