Node.js中I/O回调在事件循环阶段的执行分布及延迟回调时机确认

核心区别速览 #

• Poll阶段：处理绝大多数正常I/O回调（比如文件读取完成、TCP连接成功的回调），同时负责等待新的I/O事件触发，是事件循环中最核心的处理阶段。
• Pending Callbacks阶段：专门处理延迟到下一个循环周期的I/O回调，典型场景包括：
  • 系统级I/O错误的回调（比如TCP连接失败、端口绑定失败的错误回调）
  • 前一个循环周期中被推迟执行的I/O操作回调

实用代码示例 #

示例1：直观区分两个阶段的回调执行顺序 #

这个例子用正常文件读取（Poll阶段执行）、失败的TCP连接（Pending Callbacks阶段执行），配合微任务和Check阶段回调做标记，清晰展示执行顺序：

const fs = require('fs');
const net = require('net');

console.log('=== 事件循环启动 ===');

// 1. 正常I/O：fs.readFile回调在Poll阶段执行
fs.readFile(__filename, (err) => {
  console.log('📝 fs.readFile 回调执行（Poll阶段）');
});

// 2. 触发延迟I/O回调：连接不存在的端口，错误回调进入Pending Callbacks阶段
const socket = net.connect(9999, 'localhost');
socket.on('error', () => {
  console.log('❌ net.connect 错误回调执行（Pending Callbacks阶段）');
});

// 3. Check阶段回调：在Poll阶段之后执行
setImmediate(() => {
  console.log('⏱️ setImmediate 回调执行（Check阶段）');
});

// 4. 微任务：当前阶段结束后立即执行，优先于所有下一个阶段
process.nextTick(() => {
  console.log('⚡ process.nextTick 微任务执行');
});

console.log('=== 当前同步代码执行完毕 ===');

执行顺序解析：

1. 先跑完所有同步代码，打印启动和同步完毕信息
2. 执行微任务process.nextTick
3. 进入Poll阶段，执行fs.readFile的回调
4. Poll阶段无更多待处理I/O事件，进入Check阶段执行setImmediate
5. 开启下一轮事件循环，首先进入Pending Callbacks阶段，执行net.connect的错误回调

示例2：验证延迟回调的跨循环特性 #

这个例子通过两轮循环的Check阶段标记，确认延迟回调是在下一轮循环执行：

const net = require('net');

console.log('=== 第一轮循环开始 ===');

setImmediate(() => {
  console.log('⏱️ 第一轮 Check 阶段');
  // 第二轮循环的Check阶段回调
  setImmediate(() => {
    console.log('⏱️ 第二轮 Check 阶段');
  });
});

// 延迟I/O回调会在第一轮循环后的Pending Callbacks阶段执行
const socket = net.connect(9999);
socket.on('error', () => {
  console.log('❌ 延迟I/O回调执行（第二轮循环的Pending Callbacks阶段）');
});

console.log('=== 第一轮同步代码结束 ===');

预期执行结果：

=== 第一轮循环开始 ===
=== 第一轮同步代码结束 ===
⏱️ 第一轮 Check 阶段
❌ 延迟I/O回调执行（第二轮循环的Pending Callbacks阶段）
⏱️ 第二轮 Check 阶段

延迟I/O回调的判断关键点 #

• 触发系统级I/O错误的操作，对应的错误回调大概率进入Pending Callbacks阶段
• 延迟回调一定是跨事件循环周期执行，不会和当前循环的Poll阶段回调同批处理
• 可以用setImmediate标记Check阶段，延迟回调会出现在第一轮Check之后、第二轮Check之前

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