JavaScript事件循环与异步(js事件循环队列)
ztj100 2025-07-09 18:38 14 浏览 0 评论
概述
JavaScript是单线程的,意味着它按单一序列执行代码。但多亏了事件循环和异步特性如setTimeout、Promises和async/await,它可以处理I/O操作、定时器和HTTP请求等任务而不会阻塞执行。
事件循环:核心概念
事件循环允许JavaScript通过将非阻塞操作放入队列并继续执行其他代码来执行非阻塞操作。当调用栈清空时,它检查队列并处理下一个任务。
涉及的组件
调用栈(Call Stack)
JavaScript代码执行的地方。它是LIFO(后进先出)。
Web APIs(由浏览器提供)
处理定时器、DOM事件、fetch请求等。
回调队列(任务队列)
存储要在栈清空后执行的回调函数。
微任务队列(Microtask Queue)
用于promises和queueMicrotask。比回调队列具有更高的优先级。
工作原理(简化流程)
console.log("Start");
setTimeout(() => {
console.log("Timeout");
}, 0);
Promise.resolve().then(() => {
console.log("Promise");
});
console.log("End");
// 输出:
// Start
// End
// Promise
// Timeout
为什么?
- console.log("Start") → 同步 → 立即执行
- setTimeout(...) → 发送到Web APIs → 延迟后将回调发送到任务队列
- Promise.then(...) → 微任务队列
- console.log("End") → 同步 → 执行
- 微任务队列运行:Promise
- 任务队列运行:Timeout
异步JavaScript工具
1. setTimeout / setInterval – 调度任务
// 基本用法
setTimeout(() => {
console.log('3秒后执行');
}, 3000);
// 清除定时器
const timerId = setTimeout(() => {
console.log('这个不会执行');
}, 5000);
clearTimeout(timerId);
// 间隔执行
const intervalId = setInterval(() => {
console.log('每秒执行一次');
}, 1000);
// 5秒后停止
setTimeout(() => {
clearInterval(intervalId);
}, 5000);
2. Promises – 表示未来值
// 创建Promise
const myPromise = new Promise((resolve, reject) => {
// 异步操作
setTimeout(() => {
const random = Math.random();
if (random > 0.5) {
resolve(`成功!随机数:${random}`);
} else {
reject(`失败!随机数:${random}`);
}
}, 1000);
});
// 使用Promise
myPromise
.then(result => {
console.log('成功:', result);
})
.catch(error => {
console.log('错误:', error);
})
.finally(() => {
console.log('无论成功失败都会执行');
});
// Promise链式调用
fetch('https://api.example.com/data')
.then(response => response.json())
.then(data => {
console.log('数据:', data);
return fetch('https://api.example.com/more-data');
})
.then(response => response.json())
.then(moreData => {
console.log('更多数据:', moreData);
})
.catch(error => {
console.error('请求失败:', error);
});
3. async/await – 处理promises的语法糖
async function fetchData() {
console.log("开始获取...");
const response = await fetch("https://api.example.com");
const data = await response.json();
console.log("完成:", data);
}
fetchData();
console.log("这个先运行");
详细示例和解释
1. 事件循环执行顺序示例
console.log('1. 同步代码开始');
setTimeout(() => {
console.log('2. setTimeout 0ms');
}, 0);
setTimeout(() => {
console.log('3. setTimeout 100ms');
}, 100);
Promise.resolve().then(() => {
console.log('4. Promise微任务');
});
Promise.resolve().then(() => {
console.log('5. 另一个Promise微任务');
});
console.log('6. 同步代码结束');
// 输出顺序:
// 1. 同步代码开始
// 6. 同步代码结束
// 4. Promise微任务
// 5. 另一个Promise微任务
// 2. setTimeout 0ms
// 3. setTimeout 100ms
2. 微任务队列优先级
console.log('开始');
setTimeout(() => {
console.log('setTimeout 1');
Promise.resolve().then(() => {
console.log('setTimeout 1 中的 Promise');
});
}, 0);
setTimeout(() => {
console.log('setTimeout 2');
}, 0);
Promise.resolve().then(() => {
console.log('Promise 1');
Promise.resolve().then(() => {
console.log('Promise 1 中的 Promise');
});
});
Promise.resolve().then(() => {
console.log('Promise 2');
});
console.log('结束');
// 输出顺序:
// 开始
// 结束
// Promise 1
// Promise 2
// Promise 1 中的 Promise
// setTimeout 1
// setTimeout 1 中的 Promise
// setTimeout 2
3. 实际应用示例
用户界面更新
async function updateUserInterface() {
console.log('开始更新UI');
// 模拟API调用
const userData = await fetchUserData();
// 更新DOM(微任务)
Promise.resolve().then(() => {
updateUserProfile(userData);
});
// 显示加载状态
showLoadingSpinner();
// 延迟隐藏加载状态
setTimeout(() => {
hideLoadingSpinner();
}, 1000);
console.log('UI更新完成');
}
function fetchUserData() {
return new Promise((resolve) => {
setTimeout(() => {
resolve({ name: '张三', email: 'zhangsan@example.com' });
}, 2000);
});
}
function updateUserProfile(userData) {
console.log('更新用户资料:', userData);
}
function showLoadingSpinner() {
console.log('显示加载动画');
}
function hideLoadingSpinner() {
console.log('隐藏加载动画');
}
updateUserInterface();
错误处理
async function handleUserAction() {
try {
console.log('开始用户操作');
// 模拟多个异步操作
const [userData, userPreferences] = await Promise.all([
fetchUserData(),
fetchUserPreferences()
]);
// 处理数据
const processedData = await processUserData(userData);
// 保存结果
await saveUserData(processedData);
console.log('用户操作完成');
} catch (error) {
console.error('操作失败:', error);
// 显示错误消息
showErrorMessage(error.message);
}
}
function fetchUserData() {
return new Promise((resolve, reject) => {
setTimeout(() => {
if (Math.random() > 0.3) {
resolve({ id: 1, name: '用户' });
} else {
reject(new Error('获取用户数据失败'));
}
}, 1000);
});
}
function fetchUserPreferences() {
return new Promise((resolve) => {
setTimeout(() => {
resolve({ theme: 'dark', language: 'zh' });
}, 500);
});
}
function processUserData(data) {
return new Promise((resolve) => {
setTimeout(() => {
resolve({ ...data, processed: true });
}, 300);
});
}
function saveUserData(data) {
return new Promise((resolve, reject) => {
setTimeout(() => {
if (Math.random() > 0.2) {
resolve('保存成功');
} else {
reject(new Error('保存失败'));
}
}, 800);
});
}
function showErrorMessage(message) {
console.log('显示错误:', message);
}
handleUserAction();
4. 性能优化技巧
避免阻塞事件循环
// 不良实践:阻塞事件循环
function heavyComputation() {
const start = Date.now();
// 模拟重计算
for (let i = 0; i < 1000000000; i++) {
// 大量计算
}
console.log(`计算耗时:${Date.now() - start}ms`);
}
// 良好实践:使用setTimeout分割任务
function nonBlockingComputation() {
const start = Date.now();
let i = 0;
function processChunk() {
const chunkSize = 1000000;
const end = Math.min(i + chunkSize, 1000000000);
for (; i < end; i++) {
// 处理一小块数据
}
if (i < 1000000000) {
// 还有更多工作要做,继续处理
setTimeout(processChunk, 0);
} else {
// 完成
console.log(`计算耗时:${Date.now() - start}ms`);
}
}
processChunk();
}
// 使用Web Workers进行真正的并行处理
function useWebWorker() {
const worker = new Worker('worker.js');
worker.postMessage({ type: 'heavyComputation' });
worker.onmessage = function(event) {
console.log('计算结果:', event.data);
};
}
批量DOM更新
// 不良实践:频繁DOM更新
function updateListBad(items) {
items.forEach(item => {
const element = document.createElement('div');
element.textContent = item.name;
document.body.appendChild(element);
});
}
// 良好实践:批量更新
function updateListGood(items) {
// 使用DocumentFragment减少重排
const fragment = document.createDocumentFragment();
items.forEach(item => {
const element = document.createElement('div');
element.textContent = item.name;
fragment.appendChild(element);
});
document.body.appendChild(fragment);
}
// 使用requestAnimationFrame优化动画
function smoothAnimation() {
let start = null;
function animate(timestamp) {
if (!start) start = timestamp;
const progress = timestamp - start;
// 更新动画
const element = document.getElementById('animated');
element.style.transform = `translateX(${progress / 10}px)`;
if (progress < 1000) {
requestAnimationFrame(animate);
}
}
requestAnimationFrame(animate);
}
常见陷阱和解决方案
1. 回调地狱
// 回调地狱
function getUserData(userId, callback) {
fetchUser(userId, (user) => {
fetchUserPosts(user.id, (posts) => {
fetchUserComments(posts[0].id, (comments) => {
callback({ user, posts, comments });
});
});
});
}
// 使用Promise
async function getUserData(userId) {
const user = await fetchUser(userId);
const posts = await fetchUserPosts(user.id);
const comments = await fetchUserComments(posts[0].id);
return { user, posts, comments };
}
// 使用Promise.all并行请求
async function getUserDataParallel(userId) {
const user = await fetchUser(userId);
const [posts, comments] = await Promise.all([
fetchUserPosts(user.id),
fetchUserComments(user.id)
]);
return { user, posts, comments };
}
2. 错误处理
// 忽略错误
async function badErrorHandling() {
const data = await fetchData();
processData(data); // 如果fetchData失败,这里会抛出错误
}
// 正确错误处理
async function goodErrorHandling() {
try {
const data = await fetchData();
processData(data);
} catch (error) {
console.error('处理数据时出错:', error);
showErrorMessage('操作失败,请重试');
}
}
// 使用.catch()
async function alternativeErrorHandling() {
const data = await fetchData().catch(error => {
console.error('获取数据失败:', error);
return null;
});
if (data) {
processData(data);
}
}
3. 内存泄漏
// 可能导致内存泄漏
function badTimer() {
setInterval(() => {
console.log('定时器运行');
}, 1000);
// 没有清理定时器
}
// 正确清理
function goodTimer() {
const intervalId = setInterval(() => {
console.log('定时器运行');
}, 1000);
// 在组件卸载时清理
return () => {
clearInterval(intervalId);
};
}
// 在React组件中使用
function TimerComponent() {
useEffect(() => {
const intervalId = setInterval(() => {
console.log('定时器运行');
}, 1000);
return () => clearInterval(intervalId);
}, []);
return <div>定时器组件</div>;
}
总结
- JavaScript通过事件循环实现非阻塞:异步操作通过Web APIs延迟执行,并通过任务队列和微任务队列排队。
- Promise和async/await使异步代码更易读和管理:它们提供了更清晰的语法来处理异步操作。
- 微任务(Promises)总是在任务(setTimeout等)之前运行:这是事件循环的重要特性。
- 理解执行顺序对于调试异步代码至关重要:掌握事件循环的工作原理有助于避免常见的陷阱。
- 性能优化需要避免阻塞事件循环:使用适当的异步模式和工具来保持应用的响应性。
相关推荐
- Linux集群自动化监控系统Zabbix集群搭建到实战
-
自动化监控系统...
- systemd是什么如何使用_systemd/system
-
systemd是什么如何使用简介Systemd是一个在现代Linux发行版中广泛使用的系统和服务管理器。它负责启动系统并管理系统中运行的服务和进程。使用管理服务systemd可以用来启动、停止、...
- Linux服务器日常巡检脚本分享_linux服务器监控脚本
-
Linux系统日常巡检脚本,巡检内容包含了,磁盘,...
- 7,MySQL管理员用户管理_mysql 管理员用户
-
一、首次设置密码1.初始化时设置(推荐)mysqld--initialize--user=mysql--datadir=/data/3306/data--basedir=/usr/local...
- Python数据库编程教程:第 1 章 数据库基础与 Python 连接入门
-
1.1数据库的核心概念在开始Python数据库编程之前,我们需要先理解几个核心概念。数据库(Database)是按照数据结构来组织、存储和管理数据的仓库,它就像一个电子化的文件柜,能让我们高效...
- Linux自定义开机自启动服务脚本_linux添加开机自启动脚本
-
设置WGCloud开机自动启动服务init.d目录下新建脚本在/etc/rc.d/init.d新建启动脚本wgcloudstart.sh,内容如下...
- linux系统启动流程和服务管理,带你进去系统的世界
-
Linux启动流程Rhel6启动过程:开机自检bios-->MBR引导-->GRUB菜单-->加载内核-->init进程初始化Rhel7启动过程:开机自检BIOS-->M...
- CentOS7系统如何修改主机名_centos更改主机名称
-
请关注本头条号,每天坚持更新原创干货技术文章。如需学习视频,请在微信搜索公众号“智传网优”直接开始自助视频学习1.前言本文将讲解CentOS7系统如何修改主机名。...
- 前端工程师需要熟悉的Linux服务器(SSH 终端操作)指令
-
在Linux服务器管理中,SSH(SecureShell)是远程操作的核心工具。以下是SSH终端操作的常用命令和技巧,涵盖连接、文件操作、系统管理等场景:一、SSH连接服务器1.基本连接...
- Linux开机自启服务完全指南:3步搞定系统服务管理器配置
-
为什么需要配置开机自启?想象一下:电商服务器重启后,MySQL和Nginx没自动启动,整个网站瘫痪!这就是为什么开机自启是Linux运维的必备技能。自启服务能确保核心程序在系统启动时自动运行,避免人工...
- Kubernetes 高可用(HA)集群部署指南
-
Kubernetes高可用(HA)集群部署指南本指南涵盖从概念理解、架构选择,到kubeadm高可用部署、生产优化、监控备份和运维的全流程,适用于希望搭建稳定、生产级Kubernetes集群...
- Linux项目开发,你必须了解Systemd服务!
-
1.Systemd简介...
- Linux系统systemd服务管理工具使用技巧
-
简介:在Linux系统里,systemd就像是所有进程的“源头”,它可是系统中PID值为1的进程哟。systemd其实是一堆工具的组合,它的作用可不止是启动操作系统这么简单,像后台服务...
- Linux下NetworkManager和network的和平共处
-
简介我们在使用CentoOS系统时偶尔会遇到配置都正确但network启动不了的问题,这问题经常是由NetworkManager引起的,关闭NetworkManage并取消开机启动network就能正...
你 发表评论:
欢迎- 一周热门
-
-
MySQL中这14个小玩意,让人眼前一亮!
-
旗舰机新标杆 OPPO Find X2系列正式发布 售价5499元起
-
面试官:使用int类型做加减操作,是线程安全吗
-
C++编程知识:ToString()字符串转换你用正确了吗?
-
【Spring Boot】WebSocket 的 6 种集成方式
-
PyTorch 深度学习实战(26):多目标强化学习Multi-Objective RL
-
pytorch中的 scatter_()函数使用和详解
-
与 Java 17 相比,Java 21 究竟有多快?
-
基于TensorRT_LLM的大模型推理加速与OpenAI兼容服务优化
-
这一次,彻底搞懂Java并发包中的Atomic原子类
-
- 最近发表
-
- Linux集群自动化监控系统Zabbix集群搭建到实战
- systemd是什么如何使用_systemd/system
- Linux服务器日常巡检脚本分享_linux服务器监控脚本
- 7,MySQL管理员用户管理_mysql 管理员用户
- Python数据库编程教程:第 1 章 数据库基础与 Python 连接入门
- Linux自定义开机自启动服务脚本_linux添加开机自启动脚本
- linux系统启动流程和服务管理,带你进去系统的世界
- CentOS7系统如何修改主机名_centos更改主机名称
- 前端工程师需要熟悉的Linux服务器(SSH 终端操作)指令
- Linux开机自启服务完全指南:3步搞定系统服务管理器配置
- 标签列表
-
- idea eval reset (50)
- vue dispatch (70)
- update canceled (42)
- order by asc (53)
- spring gateway (67)
- 简单代码编程 贪吃蛇 (40)
- transforms.resize (33)
- redisson trylock (35)
- 卸载node (35)
- np.reshape (33)
- torch.arange (34)
- npm 源 (35)
- vue3 deep (35)
- win10 ssh (35)
- vue foreach (34)
- idea设置编码为utf8 (35)
- vue 数组添加元素 (34)
- std find (34)
- tablefield注解用途 (35)
- python str转json (34)
- java websocket客户端 (34)
- tensor.view (34)
- java jackson (34)
- vmware17pro最新密钥 (34)
- mysql单表最大数据量 (35)