Promise基本使用
Promise 是什么?
抽象表达:
Promise 是一门新的技术(ES6 规范)
Promise 是 JS 中进行异步编程的新解决方案
备注:旧方案是单纯使用回调函数
具体表达:
从语法上来说: Promise 是一个构造函数
从功能上来说: promise 对象用来封装一个异步操作并可以获取其成功/失败的结果值
promise 的状态改变
- pending 变为 resolved
- pending 变为 rejected
说明: 只有这 2 种, 且一个 promise 对象只能改变一次
无论变为成功还是失败, 都会有一个结果数据
成功的结果数据一般称为 value, 失败的结果数据一般称为 reason
promise 的基本流程

Promise 初体验
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72
| <!doctype html> <html lang="en"> <head> <meta charset="UTF-8"> <title>基本使用</title> <link crossorigin='anonymous' href="https://cdn.bootcss.com/twitter-bootstrap/3.3.7/css/bootstrap.min.css" rel="stylesheet"> </head> <body> <div class="container"> <h2 class="page-header">Promise 初体验</h2> <button class="btn btn-primary" id="btn">点击抽奖</button> </div> <script> function rand(m,n){ return Math.ceil(Math.random() * (n-m+1)) + m-1; }
const btn = document.querySelector('#btn'); btn.addEventListener('click', function(){
const p = new Promise((resolve, reject) => { setTimeout(() => { let n = rand(1, 100); if(n <= 30){ resolve(n); }else{ reject(n); } }, 1000); });
console.log(p); p.then((value) => { alert('恭喜恭喜, 奖品为 10万 RMB 劳斯莱斯优惠券, 您的中奖数字为 ' + value); }, (reason) => { alert('再接再厉, 您的号码为 ' + reason); });
});
</script> </body>
</html>
|
Promise实践练习-fs模块
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26
| const fs = require('fs');
let p = new Promise((resolve , reject) => { fs.readFile('./resource/content.tx', (err, data) => { if(err) reject(err); resolve(data); }); });
p.then(value=>{ console.log(value.toString()); }, reason=>{ console.log(reason); });
|
Promise实践练习-AJAX请求
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise 封装 AJAX</title> <link crossorigin='anonymous' href="https://cdn.bootcss.com/twitter-bootstrap/3.3.7/css/bootstrap.min.css" rel="stylesheet"> </head> <body> <div class="container"> <h2 class="page-header">Promise 封装 AJAX 操作</h2> <button class="btn btn-primary" id="btn">点击发送 AJAX</button> </div> <script> const btn = document.querySelector('#btn');
btn.addEventListener('click', function(){ const p = new Promise((resolve, reject) => { const xhr = new XMLHttpRequest(); xhr.open('GET', 'https://api.apiopen.top/getJoke'); xhr.send(); xhr.onreadystatechange = function(){ if(xhr.readyState === 4){ if(xhr.status >= 200 && xhr.status < 300){ resolve(xhr.response); }else{ reject(xhr.status); } } } }); p.then(value=>{ console.log(value); }, reason=>{ console.warn(reason); }); }); </script> </body> </html>
|
Promise封装练习-fs模块
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
|
function mineReadFile(path){ return new Promise((resolve, reject) => { require('fs').readFile(path, (err, data) =>{ if(err) reject(err); resolve(data); }); }); }
mineReadFile('./resource/content.txt') .then(value=>{ console.log(value.toString()); }, reason=>{ console.log(reason); });
|
util.promisify方法
1 2 3 4 5 6 7 8 9 10 11 12 13
|
const util = require('util');
const fs = require('fs');
let mineReadFile = util.promisify(fs.readFile);
mineReadFile('./resource/content.txt').then(value=>{ console.log(value.toString()); });
|
Promise封装AJAX操作
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise封装AJAX操作</title> </head> <body> <script>
function sendAJAX(url){ return new Promise((resolve, reject) => { const xhr = new XMLHttpRequest(); xhr.responseType = 'json'; xhr.open("GET", url); xhr.send(); xhr.onreadystatechange = function(){ if(xhr.readyState === 4){ if(xhr.status >= 200 && xhr.status < 300){ resolve(xhr.response); }else{ reject(xhr.status); } } } }); } sendAJAX('https://api.apiopen.top/getJok') .then(value => { console.log(value); }, reason => { console.warn(reason); }); </script> </body> </html>
|
Promise-API
Promise 构造函数: Promise (excutor) {}
- executor 函数: 执行器 (resolve, reject) => {}
- resolve 函数: 内部定义成功时我们调用的函数 value => {}
- reject 函数: 内部定义失败时我们调用的函数 reason => {}
说明: executor 会在 Promise 内部立即同步调用,异步操作在执行器中执行
Promise.prototype.then 方法: (onResolved, onRejected) => {}
- onResolved 函数: 成功的回调函数 (value) => {}
- onRejected 函数: 失败的回调函数 (reason) => {}
说明: 指定用于得到成功 value 的成功回调和用于得到失败 reason 的失败回调返回一个新的 promise 对象
Promise.prototype.catch 方法: (onRejected) => {}
- onRejected 函数: 失败的回调函数 (reason) => {}
说明: then()的语法糖, 相当于: then(undefined, onRejected)
Promise.resolve 方法: (value) => {}
说明: 返回一个成功/失败的 promise 对象
Promise.reject 方法: (reason) => {}
说明: 返回一个失败的 promise 对象
Promise.all 方法: (promises) => {}
- promises: 包含 n 个 promise 的数组
说明: 返回一个新的 promise, 只有所有的 promise 都成功才成功, 只要有一个失败了就直接失败
Promise.race 方法: (promises) => {}
- promises: 包含 n 个 promise 的数组
说明: 返回一个新的 promise, 第一个完成的 promise 的结果状态就是最终的结果状态
Promise的API-then和catch
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise API</title> </head> <body> <script> let p = new Promise((resolve, reject) => { reject('error'); });
p.catch(reason => { console.log(reason); }); </script> </body> </html>
|
Promise的API-resolve
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise API - resolve</title> </head> <body> <script> let p1 = Promise.resolve(521); let p2 = Promise.resolve(new Promise((resolve, reject) => { reject('Error'); })); p2.catch(reason => { console.log(reason); }) </script> </body> </html>
|
Promise的API-reject
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise API - reject</title> </head> <body> <script> let p3 = Promise.reject(new Promise((resolve, reject) => { resolve('OK'); })); console.log(p3); </script> </body> </html>
|
Promise的API-all
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise API - all</title> </head> <body> <script> let p1 = new Promise((resolve, reject) => { resolve('OK'); }) let p2 = Promise.reject('Error'); let p3 = Promise.resolve('Oh Yeah'); const result = Promise.all([p1, p2, p3]);
console.log(result); </script> </body> </html>
|
Promise的API-race
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51
| <!DOCTYPE html> <html lang="en">
<head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise API - race</title> </head> <body> <script> let p1 = new Promise((resolve, reject) => { setTimeout(() => { resolve('OK'); }, 1000); }) let p2 = Promise.resolve('Success'); let p3 = Promise.resolve('Oh Yeah');
const result = Promise.race([p1, p2, p3]);
console.log(result); </script> </body>
</html><!DOCTYPE html> <html lang="en">
<head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise API - race</title> </head> <body> <script> let p1 = new Promise((resolve, reject) => { setTimeout(() => { resolve('OK'); }, 1000); }) let p2 = Promise.resolve('Success'); let p3 = Promise.resolve('Oh Yeah');
const result = Promise.race([p1, p2, p3]);
console.log(result); </script> </body>
</html>
|
Promise的关键性问题
如何改变 promise 的状态?
resolve(value): 如果当前是 pending 就会变为 resolved
- reject(reason): 如果当前是 pending 就会变为 rejected
- 抛出异常: 如果当前是 pending 就会变为 rejected
一个 promise 指定多个成功/失败回调函数, 都会调用吗?
改变 promise 状态和指定回调函数谁先谁后?
- 都有可能, 正常情况下是先指定回调再改变状态, 但也可以先改状态再指定回调
如何先改状态再指定回调?
在执行器中直接调用 resolve()/reject()
延迟更长时间才调用 then()
什么时候才能得到数据?
如果先指定的回调, 那当状态发生改变时, 回调函数就会调用, 得到数据
如果先改变的状态, 那当指定回调时, 回调函数就会调用, 得到数据
promise.then()返回的新 promise 的结果状态由什么决定?
- 简单表达: 由 then()指定的回调函数执行的结果决定
- 详细表达:
如果抛出异常, 新 promise 变为 rejected, reason 为抛出的异常
如果返回的是非 promise 的任意值, 新 promise 变为 resolved, value 为返回的值
如果返回的是另一个新 promise, 此 promise 的结果就会成为新 promise 的结果
promise 如何串连多个操作任务?
- promise 的 then()返回一个新的 promise, 可以开成 then()的链式调用
- 通过 then 的链式调用串连多个同步/异步任务
promise 异常传透?
- 当使用 promise 的 then 链式调用时, 可以在最后指定失败的回调,
- 前面任何操作出了异常, 都会传到最后失败的回调中处理
中断 promise 链?
- 当使用 promise 的 then 链式调用时, 在中间中断, 不再调用后面的回调函数
- 办法: 在回调函数中返回一个 pendding 状态的 promise 对象
Promise 对象状态改变的方式
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise关键问题 - Promise 对象状态改变的方式</title> </head> <body> <script> let p = new Promise((resolve, reject) => { });
console.log(p); </script> </body> </html>
|
Promise 指定多个回调
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise关键问题 - Promise 指定多个回调</title> </head> <body> <script> let p = new Promise((resolve, reject) => { });
p.then(value => { console.log(value); });
p.then(value => { alert(value); }); </script> </body> </html>
|
Promise 改变状态与指定回调的顺序问题
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise关键问题 - Promise 改变状态与指定回调的顺序问题</title> </head> <body> <script>
let p = new Promise((resolve, reject) => { setTimeout(() => { resolve('OK'); }, 1000); });
p.then(value => { console.log(value); },reason=>{ }) </script> </body> </html>
|
Promise then方法的返回结果特点
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise关键问题 - Promise then方法的返回结果特点</title> </head> <body> <script> let p = new Promise((resolve, reject) => { resolve('ok'); }); let result = p.then(value => { }, reason => { console.warn(reason); });
console.log(result); </script> </body> </html>
|
Promise如何串联多个任务
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise关键问题 - 如何串联多个任务</title> </head> <body> <script> let p = new Promise((resolve, reject) => { setTimeout(() => { resolve('OK'); }, 1000); });
p.then(value => { return new Promise((resolve, reject) => { resolve("success"); }); }).then(value => { console.log(value); }).then(value => { console.log(value); }) </script> </body> </html>
|
Promise异常穿透
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise关键问题 - 异常穿透</title> </head> <body> <script> let p = new Promise((resolve, reject) => { setTimeout(() => { resolve('OK'); }, 1000); });
p.then(value => { throw '失败啦!'; }).then(value => { console.log(222); }).then(value => { console.log(333); }).catch(reason => { console.warn(reason); }); </script> </body> </html>
|
Promise中断 Promise 链条
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise关键问题 - 中断 Promise 链条</title> </head> <body> <script> let p = new Promise((resolve, reject) => { setTimeout(() => { resolve('OK'); }, 1000); });
p.then(value => { console.log(111); return new Promise(() => {}); }).then(value => { console.log(222); }).then(value => { console.log(333); }).catch(reason => { console.warn(reason); }); </script> </body> </html>
|
Promise自定义封装
1-初始结构搭建
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 1 - 初始结构搭建</title> <script src="./promise.js"></script> </head> <body> <script> let p = new Promise((resolve, reject) => { resolve('OK'); });
p.then(value => { console.log(value); }, reason=>{ console.warn(reason); }) </script> </body> </html>
|
1 2 3 4 5 6 7 8 9
| function Promise(executor){
}
Promise.prototype.then = function(onResolved, onRejected){
}
|
2-resolve与reject结构搭建
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 2 - resolve 与 reject </title> <script src="./promise.js"></script> </head> <body> <script> let p = new Promise((resolve, reject) => { resolve('OK'); });
p.then(value => { console.log(value); }, reason=>{ console.warn(reason); }) </script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
| function Promise(executor){ function resolve(data){
} function reject(data){
}
executor(resolve, reject); }
Promise.prototype.then = function(onResolved, onRejected){
}
|
3-resolve与reject函数实现
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 2 - resolve 与 reject </title> <script src="./promise.js"></script> </head> <body> <script> let p = new Promise((resolve, reject) => { reject("error"); });
console.log(p);
</script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; const self = this; function resolve(data){ self.PromiseState = 'fulfilled'; self.PromiseResult = data; } function reject(data){ self.PromiseState = 'rejected'; self.PromiseResult = data; }
executor(resolve, reject); }
Promise.prototype.then = function(onResolved, onRejected){
}
|
4-throw抛出错误改变状态
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 4 - throw 抛出异常改变状态 </title> </head> <body> <script> let p = new Promise((resolve, reject) => { throw "error"; });
console.log(p);
</script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; const self = this; function resolve(data){ self.PromiseState = 'fulfilled'; self.PromiseResult = data; } function reject(data){ self.PromiseState = 'rejected'; self.PromiseResult = data; } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){
}
|
5-状态只能修改一次
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 5 - 状态只能修改一次 </title> <script src="./promise.js"></script> </head> <body> <script> let p = new Promise((resolve, reject) => { reject("error"); resolve('OK'); });
console.log(p); </script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){
}
|
6-then方法执行回调
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 6 - then 方法执行回调 </title> <script src="./promise.js"></script> </head> <body> <script> let p = new Promise((resolve, reject) => { throw "ERROR"; });
p.then(value => { console.log(value); }, reason=>{ console.warn(reason); }) </script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){ if(this.PromiseState === 'fulfilled'){ onResolved(this.PromiseResult); } if(this.PromiseState === 'rejected'){ onRejected(this.PromiseResult); } }
|
7-异步任务then方法执行回调
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 7 - 异步任务 then 方法实现 </title> <script src="./promise.js"></script> </head> <body> <script> let p = new Promise((resolve, reject) => { setTimeout(() => { reject("error"); }, 1000); });
p.then(value => { console.log(value); }, reason=>{ console.warn(reason); });
console.log(p); </script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; this.callback = {}; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; if(self.callback.onResolved){ self.callback.onResolved(data); } } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; if(self.callback.onResolved){ self.callback.onResolved(data); } } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){ if(this.PromiseState === 'fulfilled'){ onResolved(this.PromiseResult); } if(this.PromiseState === 'rejected'){ onRejected(this.PromiseResult); } if(this.PromiseState === 'pending'){ this.callback = { onResolved: onResolved, onRejected: onRejected } } }
|
8-指定多个回调
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 8 - 指定多个回调 </title> <script src="./promise.js"></script> </head> <body> <script> let p = new Promise((resolve, reject) => { setTimeout(() => { reject('No'); }, 1000); });
p.then(value => { console.log(value); }, reason=>{ console.warn(reason); });
p.then(value => { alert(value); }, reason=>{ alert(reason); });
console.log(p);
</script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; this.callbacks = []; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onResolved(data); }); } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onRejected(data); }); } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){ if(this.PromiseState === 'fulfilled'){ onResolved(this.PromiseResult); } if(this.PromiseState === 'rejected'){ onRejected(this.PromiseResult); } if(this.PromiseState === 'pending'){ this.callbacks.push({ onResolved: onResolved, onRejected: onRejected }); } }
|
9-同步修改状态then方法返回结果
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 9 - 同步任务 then 返回结果</title> <script src="./promise.js"></script> </head> <body> <script> let p = new Promise((resolve, reject) => { resolve('OK'); }); const res = p.then(value => { throw "FAIL"; }, reason=>{ console.warn(reason); }); console.log(res); </script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; this.callbacks = []; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onResolved(data); }); } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onRejected(data); }); } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){ return new Promise((resolve, reject) => { if(this.PromiseState === 'fulfilled'){ try{ let result = onResolved(this.PromiseResult); if(result instanceof Promise){ result.then(v => { resolve(v); }, r=>{ reject(r); }) }else{ resolve(result); } }catch(e){ reject(e); } } if(this.PromiseState === 'rejected'){ onRejected(this.PromiseResult); } if(this.PromiseState === 'pending'){ this.callbacks.push({ onResolved: onResolved, onRejected: onRejected }); } }) }
|
10-1异步修改状态then方法返回结果
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 10 - 异步任务 then 返回结果</title> <script src="./promise.js"></script> </head> <body> <script> let p = new Promise((resolve, reject) => { setTimeout(() => { reject("Error"); }, 1000) });
const res = p.then(value => { throw 'error'; }, reason=>{ throw 'error'; });
console.log(res); </script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; this.callbacks = []; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onResolved(data); }); } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onRejected(data); }); } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){ const self = this; return new Promise((resolve, reject) => { if(this.PromiseState === 'fulfilled'){ try{ let result = onResolved(this.PromiseResult); if(result instanceof Promise){ result.then(v => { resolve(v); }, r=>{ reject(r); }) }else{ resolve(result); } }catch(e){ reject(e); } } if(this.PromiseState === 'rejected'){ onRejected(this.PromiseResult); } if(this.PromiseState === 'pending'){ this.callbacks.push({ onResolved: function(){ try{ let result = onResolved(self.PromiseResult); if(result instanceof Promise){ result.then(v => { resolve(v); }, r=>{ reject(r); }) }else{ resolve(result); } }catch(e){ reject(e); } }, onRejected: function(){ try{ let result = onRejected(self.PromiseResult); if(result instanceof Promise){ result.then(v => { resolve(v); }, r=>{ reject(r); }) }else{ resolve(result); } }catch(e){ reject(e); } } }); } }) }
|
10-2-then方法代码优化
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 10 - 异步任务 then 返回结果</title> <script src="./promise.js"></script> </head> <body> <script> let p = new Promise((resolve, reject) => { setTimeout(() => { resolve('ok'); }, 100); });
const res = p.then(value => { console.log(value); }, reason=>{ console.warn(reason); });
console.log(res); </script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; this.callbacks = []; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onResolved(data); }); } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onRejected(data); }); } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){ const self = this; return new Promise((resolve, reject) => { function callback(type){ try{ let result = type(self.PromiseResult); if(result instanceof Promise){ result.then(v => { resolve(v); }, r=>{ reject(r); }) }else{ resolve(result); } }catch(e){ reject(e); } } if(this.PromiseState === 'fulfilled'){ callback(onResolved); } if(this.PromiseState === 'rejected'){ callback(onRejected); } if(this.PromiseState === 'pending'){ this.callbacks.push({ onResolved: function(){ callback(onResolved); }, onRejected: function(){ callback(onRejected); } }); } }) }
|
11-catch方法与异常穿透
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 11 - catch 方法与异常穿透</title> <script src="./promise.js"></script> </head> <body> <script> let p = new Promise((resolve, reject) => { setTimeout(() => { resolve('OK'); }, 1000); });
p.then() .then(value=>{ console.log(222); }).then(value => { console.log(333); }).catch(reason => { console.warn(reason); });
</script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; this.callbacks = []; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onResolved(data); }); } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onRejected(data); }); } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){ const self = this; if(typeof onRejected !== 'function'){ onRejected = reason => { throw reason; } } if(typeof onResolved !== 'function'){ onResolved = value => value; } return new Promise((resolve, reject) => { function callback(type){ try{ let result = type(self.PromiseResult); if(result instanceof Promise){ result.then(v => { resolve(v); }, r=>{ reject(r); }) }else{ resolve(result); } }catch(e){ reject(e); } } if(this.PromiseState === 'fulfilled'){ callback(onResolved); } if(this.PromiseState === 'rejected'){ callback(onRejected); } if(this.PromiseState === 'pending'){ this.callbacks.push({ onResolved: function(){ callback(onResolved); }, onRejected: function(){ callback(onRejected); } }); } }) }
Promise.prototype.catch = function(onRejected){ return this.then(undefined, onRejected); }
|
12-Promise.resolve
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 12 - Promise.resolve 封装</title> <script src="./promise.js"></script> </head> <body> <script> const p = Promise.resolve('OK'); const p2 = Promise.resolve(new Promise((resolve, reject) => { reject("error"); })); const p3 = Promise.resolve(Promise.resolve('Oh Yeah'));
console.log(p3); </script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; this.callbacks = []; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onResolved(data); }); } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onRejected(data); }); } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){ const self = this; if(typeof onRejected !== 'function'){ onRejected = reason => { throw reason; } } if(typeof onResolved !== 'function'){ onResolved = value => value; } return new Promise((resolve, reject) => { function callback(type){ try{ let result = type(self.PromiseResult); if(result instanceof Promise){ result.then(v => { resolve(v); }, r=>{ reject(r); }) }else{ resolve(result); } }catch(e){ reject(e); } } if(this.PromiseState === 'fulfilled'){ callback(onResolved); } if(this.PromiseState === 'rejected'){ callback(onRejected); } if(this.PromiseState === 'pending'){ this.callbacks.push({ onResolved: function(){ callback(onResolved); }, onRejected: function(){ callback(onRejected); } }); } }) }
Promise.prototype.catch = function(onRejected){ return this.then(undefined, onRejected); }
Promise.resolve = function(value){ return new Promise((resolve, reject) => { if(value instanceof Promise){ value.then(v=>{ resolve(v); }, r=>{ reject(r); }) }else{ resolve(value); } }); }
|
13-Promise.reject
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 13 - Promise.reject 封装</title> <script src="./promise.js"></script> </head> <body> <script> const p = Promise.reject('Error'); const p2 = Promise.reject(new Promise((resolve, reject) => { resolve('OK'); }));
console.log(p); console.log(p2);
</script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; this.callbacks = []; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onResolved(data); }); } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onRejected(data); }); } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){ const self = this; if(typeof onRejected !== 'function'){ onRejected = reason => { throw reason; } } if(typeof onResolved !== 'function'){ onResolved = value => value; } return new Promise((resolve, reject) => { function callback(type){ try{ let result = type(self.PromiseResult); if(result instanceof Promise){ result.then(v => { resolve(v); }, r=>{ reject(r); }) }else{ resolve(result); } }catch(e){ reject(e); } } if(this.PromiseState === 'fulfilled'){ callback(onResolved); } if(this.PromiseState === 'rejected'){ callback(onRejected); } if(this.PromiseState === 'pending'){ this.callbacks.push({ onResolved: function(){ callback(onResolved); }, onRejected: function(){ callback(onRejected); } }); } }) }
Promise.prototype.catch = function(onRejected){ return this.then(undefined, onRejected); }
Promise.resolve = function(value){ return new Promise((resolve, reject) => { if(value instanceof Promise){ value.then(v=>{ resolve(v); }, r=>{ reject(r); }) }else{ resolve(value); } }); }
Promise.reject = function(reason){ return new Promise((resolve, reject)=>{ reject(reason); }); }
|
14-Promise.all方法实现
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 14 - Promise.all 封装</title> <script src="./promise.js"></script> </head> <body> <script> let p1 = new Promise((resolve, reject) => { setTimeout(() => { resolve('OK'); }, 1000) }) let p2 = Promise.reject('Success'); let p3 = Promise.resolve('Oh Yeah');
let result = Promise.all([p1, p2, p3]);
console.log(result); </script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; this.callbacks = []; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onResolved(data); }); } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onRejected(data); }); } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){ const self = this; if(typeof onRejected !== 'function'){ onRejected = reason => { throw reason; } } if(typeof onResolved !== 'function'){ onResolved = value => value; } return new Promise((resolve, reject) => { function callback(type){ try{ let result = type(self.PromiseResult); if(result instanceof Promise){ result.then(v => { resolve(v); }, r=>{ reject(r); }) }else{ resolve(result); } }catch(e){ reject(e); } } if(this.PromiseState === 'fulfilled'){ callback(onResolved); } if(this.PromiseState === 'rejected'){ callback(onRejected); } if(this.PromiseState === 'pending'){ this.callbacks.push({ onResolved: function(){ callback(onResolved); }, onRejected: function(){ callback(onRejected); } }); } }) }
Promise.prototype.catch = function(onRejected){ return this.then(undefined, onRejected); }
Promise.resolve = function(value){ return new Promise((resolve, reject) => { if(value instanceof Promise){ value.then(v=>{ resolve(v); }, r=>{ reject(r); }) }else{ resolve(value); } }); }
Promise.reject = function(reason){ return new Promise((resolve, reject)=>{ reject(reason); }); }
Promise.all = function(promises){ return new Promise((resolve, reject) => { let count = 0; let arr = []; for(let i=0;i<promises.length;i++){ promises[i].then(v => { count++; arr[i] = v; if(count === promises.length){ resolve(arr); } }, r => { reject(r); }); } }); }
|
15-Promise.race方法实现
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 15 - Promise.race 封装</title> <script src="./promise.js"></script> </head> <body> <script> let p1 = new Promise((resolve, reject) => { setTimeout(() => { resolve('OK'); }); }); let p2 = Promise.reject('Success'); let p3 = Promise.resolve('Oh Yeah');
let result = Promise.race([p1, p2, p3]);
console.log(result); </script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; this.callbacks = []; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onResolved(data); }); } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; self.callbacks.forEach(item => { item.onRejected(data); }); } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){ const self = this; if(typeof onRejected !== 'function'){ onRejected = reason => { throw reason; } } if(typeof onResolved !== 'function'){ onResolved = value => value; } return new Promise((resolve, reject) => { function callback(type){ try{ let result = type(self.PromiseResult); if(result instanceof Promise){ result.then(v => { resolve(v); }, r=>{ reject(r); }) }else{ resolve(result); } }catch(e){ reject(e); } } if(this.PromiseState === 'fulfilled'){ callback(onResolved); } if(this.PromiseState === 'rejected'){ callback(onRejected); } if(this.PromiseState === 'pending'){ this.callbacks.push({ onResolved: function(){ callback(onResolved); }, onRejected: function(){ callback(onRejected); } }); } }) }
Promise.prototype.catch = function(onRejected){ return this.then(undefined, onRejected); }
Promise.resolve = function(value){ return new Promise((resolve, reject) => { if(value instanceof Promise){ value.then(v=>{ resolve(v); }, r=>{ reject(r); }) }else{ resolve(value); } }); }
Promise.reject = function(reason){ return new Promise((resolve, reject)=>{ reject(reason); }); }
Promise.all = function(promises){ return new Promise((resolve, reject) => { let count = 0; let arr = []; for(let i=0;i<promises.length;i++){ promises[i].then(v => { count++; arr[i] = v; if(count === promises.length){ resolve(arr); } }, r => { reject(r); }); } }); }
Promise.race = function(promises){ return new Promise((resolve, reject) => { for(let i=0;i<promises.length;i++){ promises[i].then(v => { resolve(v); },r=>{ reject(r); }) } }); }
|
16-then回调函数异步执行的实现
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 16 - 回调函数『异步执行』</title> <script src="./promise.js"></script> </head> <body> <script> let p1 = new Promise((resolve, reject) => { reject('OK'); console.log(111); });
p1.then(value => { console.log(222); }, reason => { console.log(444); });
console.log(333); </script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179
| function Promise(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; this.callbacks = []; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; setTimeout(() => { self.callbacks.forEach(item => { item.onResolved(data); }); }); } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; setTimeout(() => { self.callbacks.forEach(item => { item.onRejected(data); }); }); } try{ executor(resolve, reject); }catch(e){ reject(e); } }
Promise.prototype.then = function(onResolved, onRejected){ const self = this; if(typeof onRejected !== 'function'){ onRejected = reason => { throw reason; } } if(typeof onResolved !== 'function'){ onResolved = value => value; } return new Promise((resolve, reject) => { function callback(type){ try{ let result = type(self.PromiseResult); if(result instanceof Promise){ result.then(v => { resolve(v); }, r=>{ reject(r); }) }else{ resolve(result); } }catch(e){ reject(e); } } if(this.PromiseState === 'fulfilled'){ setTimeout(() => { callback(onResolved); }); } if(this.PromiseState === 'rejected'){ setTimeout(() => { callback(onRejected); }); } if(this.PromiseState === 'pending'){ this.callbacks.push({ onResolved: function(){ callback(onResolved); }, onRejected: function(){ callback(onRejected); } }); } }) }
Promise.prototype.catch = function(onRejected){ return this.then(undefined, onRejected); }
Promise.resolve = function(value){ return new Promise((resolve, reject) => { if(value instanceof Promise){ value.then(v=>{ resolve(v); }, r=>{ reject(r); }) }else{ resolve(value); } }); }
Promise.reject = function(reason){ return new Promise((resolve, reject)=>{ reject(reason); }); }
Promise.all = function(promises){ return new Promise((resolve, reject) => { let count = 0; let arr = []; for(let i=0;i<promises.length;i++){ promises[i].then(v => { count++; arr[i] = v; if(count === promises.length){ resolve(arr); } }, r => { reject(r); }); } }); }
Promise.race = function(promises){ return new Promise((resolve, reject) => { for(let i=0;i<promises.length;i++){ promises[i].then(v => { resolve(v); },r=>{ reject(r); }) } }); }
|
17-class版本封装
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>Promise-封装 | 17 - class版本封装</title> <script src="./promise.js"></script> </head> <body> <script>
console.log(Promise.resolve('OK')); </script> </body> </html>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184
|
class Promise{ constructor(executor){ this.PromiseState = 'pending'; this.PromiseResult = null; this.callbacks = []; const self = this; function resolve(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'fulfilled'; self.PromiseResult = data; setTimeout(() => { self.callbacks.forEach(item => { item.onResolved(data); }); }); } function reject(data){ if(self.PromiseState !== 'pending') return; self.PromiseState = 'rejected'; self.PromiseResult = data; setTimeout(() => { self.callbacks.forEach(item => { item.onRejected(data); }); }); } try{ executor(resolve, reject); }catch(e){ reject(e); } }
then(onResolved,onRejected){ const self = this; if(typeof onRejected !== 'function'){ onRejected = reason => { throw reason; } } if(typeof onResolved !== 'function'){ onResolved = value => value; } return new Promise((resolve, reject) => { function callback(type){ try{ let result = type(self.PromiseResult); if(result instanceof Promise){ result.then(v => { resolve(v); }, r=>{ reject(r); }) }else{ resolve(result); } }catch(e){ reject(e); } } if(this.PromiseState === 'fulfilled'){ setTimeout(() => { callback(onResolved); }); } if(this.PromiseState === 'rejected'){ setTimeout(() => { callback(onRejected); }); } if(this.PromiseState === 'pending'){ this.callbacks.push({ onResolved: function(){ callback(onResolved); }, onRejected: function(){ callback(onRejected); } }); } }) }
catch(onRejected){ return this.then(undefined, onRejected); }
static resolve(value){ return new Promise((resolve, reject) => { if(value instanceof Promise){ value.then(v=>{ resolve(v); }, r=>{ reject(r); }) }else{ resolve(value); } }); }
static reject(reason){ return new Promise((resolve, reject)=>{ reject(reason); }); }
static all(promises){ return new Promise((resolve, reject) => { let count = 0; let arr = []; for(let i=0;i<promises.length;i++){ promises[i].then(v => { count++; arr[i] = v; if(count === promises.length){ resolve(arr); } }, r => { reject(r); }); } }); }
static race (promises){ return new Promise((resolve, reject) => { for(let i=0;i<promises.length;i++){ promises[i].then(v => { resolve(v); },r=>{ reject(r); }) } }); } }
|
async和await
async函数
函数的返回值为 promise 对象
promise 对象的结果由 async 函数执行的返回值决定
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>async函数</title> </head> <body> <script> async function main(){ throw "Oh NO"; }
let result = main();
console.log(result); </script> </body> </html>
|
await表达式
await 右侧的表达式一般为 promise 对象, 但也可以是其它的值
如果表达式是 promise 对象, await 返回的是 promise 成功的值
如果表达式是其它值, 直接将此值作为 await 的返回值
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>await</title> </head> <body> <script> async function main(){ let p = new Promise((resolve, reject) => { reject('Error'); }) try{ let res3 = await p; }catch(e){ console.log(e); } }
main(); </script> </body> </html>
|
async与await结合
注意:
await 必须写在 async 函数中, 但 async 函数中可以没有 await
如果 await 的 promise 失败了, 就会抛出异常, 需要通过 try…catch 捕获处理
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34
|
const fs = require('fs'); const util = require('util'); const mineReadFile = util.promisify(fs.readFile);
async function main(){ try{ let data1 = await mineReadFile('./resource/1x.html'); let data2 = await mineReadFile('./resource/2.html'); let data3 = await mineReadFile('./resource/3.html'); console.log(data1 + data2 + data3); }catch(e){ console.log(e.code); } }
main();
|
async与await结合发送AJAX
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>async与await结合发送AJAX</title> </head> <body> <button id="btn">点击获取段子</button> <script> function sendAJAX(url){ return new Promise((resolve, reject) => { const xhr = new XMLHttpRequest(); xhr.responseType = 'json'; xhr.open("GET", url); xhr.send(); xhr.onreadystatechange = function(){ if(xhr.readyState === 4){ if(xhr.status >= 200 && xhr.status < 300){ resolve(xhr.response); }else{ reject(xhr.status); } } } }); }
let btn = document.querySelector('#btn');
btn.addEventListener('click',async function(){ let duanzi = await sendAJAX('https://api.apiopen.top/getJoke'); console.log(duanzi); }); </script> </body> </html>
|