/** *@ promise前凑 *@ promise 好处: *@ 1.可以解决一些异步问题(异步回调--回调地狱,回调的嵌套关系) * */
//需求 当异步读取2个文件完成后 多个回调同步结果的情况 ,(需要读取a和b 等2个文件,当读取完后需要显示)(a.txt 里 hello ; b.txt 里 word) //方法1 使用回调函数 callback, 当我们读取完后 判断是不是读取2次,如果是就显示
let fs = require("fs");//我们 可以先定义一个 after 方法,判断2次执行完显示结果function after(times, callback) { let arr=[]; return function (data) { arr.push(data); //如果执行完2次 显示结果 if (--times == 0){ callback(arr); } }}let fn =after(2,function (data) { console.log(data);});fs.readFile("a.txt", "utf8", function (err, data) { fn(data)});fs.readFile("b.txt","utf8",function (err, data) { fn(data)}); //执行后 查看控制台 ===》[ 'hello', 'Word' ]
// 方法2 使用 发布订阅 模式 发布订阅 发布(发布时一次执行) 订阅(先把他暂存起来)
let fs = require("fs");let event = { arr: [], result: [], on(fn) { this.arr.push(fn); }, emit(data) { this.result.push(data); this.arr.forEach(fn=>fn(this.result)); }};event.on(function (data) { if(data.length==2){ console.log(data);//这是最终输出的结果 }})fs.readFile("a.txt","utf8",function (err,data) { event.emit(data);})fs.readFile("b.txt","utf8",function (err,data) { event.emit(data);})
输出的结果 和方法1 一样