Node.js的事件循环是处理异步操作的核心机制,它由多个不同阶段组成,每个阶段都有特定的任务处理规则。想要手动控制事件循环的阶段,首先需要清楚各阶段的执行顺序和特点,再结合对应的API进行干预。

Node.js事件循环的阶段划分
Node.js的事件循环按照固定顺序循环执行以下阶段,每个阶段处理一类特定的回调任务:
- timers阶段:执行setTimeout和setInterval设定的回调
- pending callbacks阶段:执行上一轮循环中未被处理的I/O回调
- idle, prepare阶段:内部使用的准备阶段,开发者一般无需关注
- poll阶段:检索新的I/O事件,执行I/O相关回调,是事件循环中停留时间最长的阶段
- check阶段:执行setImmediate设定的回调
- close callbacks阶段:执行关闭事件的回调,比如socket.on('close', ...)
手动控制各阶段的常用方法
1. 控制timers阶段执行
timers阶段的触发依赖设定的时间阈值,我们可以通过调整setTimeout的延迟时间,让回调在指定的timers阶段执行。如果需要立即触发timers阶段的回调,可以将延迟设为0,但注意0延迟的setTimeout会等到当前执行栈清空后,在下一个timers阶段执行,不是立刻执行。
// 设定1秒后在timers阶段执行回调
setTimeout(() => {
console.log('timers阶段回调执行');
}, 1000);
// 0延迟的setTimeout,会在下一个事件循环的timers阶段执行
setTimeout(() => {
console.log('0延迟的timers回调');
}, 0);2. 让任务在check阶段执行
setImmediate是Node.js特有的API,它的回调会在check阶段执行,不受timers阶段的时间影响。如果需要在poll阶段结束后立刻执行任务,可以使用setImmediate,它的执行时机比0延迟的setTimeout更早。
// setImmediate的回调会在check阶段执行
setImmediate(() => {
console.log('check阶段回调执行');
});
// 对比0延迟setTimeout和setImmediate的执行顺序
setTimeout(() => {
console.log('0延迟setTimeout回调');
}, 0);
// 上述两个回调的执行顺序在Node.js中通常是setImmediate先执行,除非在I/O循环内3. 干预poll阶段的执行
poll阶段是事件循环中处理I/O任务的核心阶段,默认会等待新的I/O事件。我们可以通过process.nextTick让任务在当前阶段结束后、下一个阶段开始前执行,它的优先级比所有事件循环阶段的回调都高。
// process.nextTick的回调会在当前操作完成后立刻执行,不属于事件循环的任何阶段
process.nextTick(() => {
console.log('nextTick回调,优先级最高');
});
setImmediate(() => {
console.log('check阶段回调');
});
// 输出顺序:先输出nextTick回调,再输出check阶段回调4. 利用Promise微任务控制执行时序
Promise的回调属于微任务,会在当前事件循环阶段的所有宏任务执行完成后执行,优先级仅次于process.nextTick。我们可以通过Promise的resolve来插入微任务,调整任务的执行顺序。
Promise.resolve().then(() => {
console.log('Promise微任务回调');
});
process.nextTick(() => {
console.log('nextTick回调');
});
setImmediate(() => {
console.log('check阶段回调');
});
// 输出顺序:nextTick回调 -> Promise微任务回调 -> check阶段回调实际场景中的控制示例
假设我们需要在文件读取完成后,先执行一段同步逻辑,再执行事件循环的check阶段任务,可以结合process.nextTick和setImmediate实现:
const fs = require('fs');
const { promisify } = require('util');
const readFile = promisify(fs.readFile);
readFile('./test.txt').then((data) => {
console.log('文件读取完成');
// 在当前阶段结束后立刻执行同步逻辑
process.nextTick(() => {
console.log('文件读取后的同步处理逻辑');
});
// 让后续任务在check阶段执行
setImmediate(() => {
console.log('check阶段的后续任务');
});
});通过上述方法,我们可以根据实际需求,将任务安排到事件循环的不同阶段执行,精准控制异步任务的时序,避免因为执行顺序问题导致的逻辑错误。