如何让Node.js子进程message处理器支持async/await？

问题描述 #

编写async/await代码时遇到问题：Node.js子进程的message处理器能否变为异步？当前代码中子进程会在slowFunction执行完成前提前退出，且无法直接给message处理器添加async修饰符，寻求解决办法。

子进程代码（child.ts） #

import { writeImage } from './generate-images'

const slowFunction = async (imageAttributes) => {
    console.log("inside child slowFunction....")
    await writeImage(imageAttributes, 0, true)
}

process.on('message', (msg) => {
    console.log('starting child....')
    slowFunction(msg)
    console.log('exiting child')
    process.exit()
})

父进程代码（parent.ts，简化版） #

const child = child_process.fork(path.join(__dirname, 'child.ts'))

child.send(Array.from(imageAttributes)[i])

child.on('exit', function () {
    console.log(`child exiting`)
    // do some cleanup
})

解决方案 #

问题核心是：当前message处理器调用异步函数slowFunction时没有使用await，导致代码直接跳过异步逻辑执行process.exit()，子进程提前退出。实际上事件处理器支持添加async修饰符，只需调整代码逻辑保证异步任务完成后再退出：

1. 给message处理器添加async修饰符
2. 在处理器内await slowFunction(msg)，确保异步任务执行完成
3. 添加错误捕获，避免异步任务抛出异常导致子进程意外退出

修改后的子进程代码：

import { writeImage } from './generate-images'

const slowFunction = async (imageAttributes) => {
    console.log("inside child slowFunction....")
    await writeImage(imageAttributes, 0, true)
}

process.on('message', async (msg) => {
    try {
        console.log('starting child....')
        await slowFunction(msg)
        console.log('exiting child')
        process.exit(0) // 正常退出用0码
    } catch (err) {
        console.error('子进程执行出错:', err)
        process.exit(1) // 异常退出用非0码
    }
})

说明 #

• 父进程代码无需修改，子进程会在slowFunction执行完成后才触发退出，父进程的exit事件也会在正确时机触发
• 添加try/catch是为了捕获异步任务中的异常，避免未处理的Promise拒绝导致子进程崩溃而非正常退出

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