最近在看node社区的nodeclub源码,看到一个玩意EventProxy,这里记录一下基本语法
nodeclub社区源码:https://github.com/cnodejs/
eventproxy工具源码:https://github.com/JacksonTia
EventProxy 可以理解为一个基于事件机制对复杂的业务逻辑进行解耦的工具,可以解决javascript异步回调地狱问题的工具。
先来看一段回调嵌套的示例代码:
准备工作:三个文件file1.txt,file2.txt, file3.txt文件,在里面随便写点内容
var fs = require('fs');
fs.readFile('./file1.txt', 'utf8', function (err1, data1) {
fs.readFile('./file2.txt', 'utf8', function (err2, data2) {
fs.readFile('./file3.txt', 'utf8', function (err3, data3) {
console.log(data1 + data2 + data3);
});
});
});
这种代码在node中是不是经常见??
看着是不是有点心疼的感觉~哈哈,看到两句有意思的话:这个世界上不存在所谓回调函数深度嵌套的问题。世界上本没有嵌套回调,写得人多了,也便有了}}}}}}}}}}}}。
正题:
安装eventproxy
npm install eventproxy
使用
var EventProxy = require('eventproxy');
var ep = new EventProxy();
常用方法分为两部分:
解决回调的方法:
优化代码的方法:
emit()方法、all()方法
var fs = require('fs');
var EventProxy = require('eventproxy');
var ep = new EventProxy();
// all()方法用于指定接收哪几种事件,并在回调函数中进行统一处理,回调函数可以接收事件中携带的参数,参数位置与事件位置一一对应
ep.all(['read_file1', 'read_file2', 'read_file3'], function (data1, data2, data3) {
console.log(data1 + data2 + data3);
});
fs.readFile('/file1.txt', 'utf8', function (err, data) {
// 使用emit抛出一个事件 read_file1
ep.emit('read_file1', data);
});
fs.readFile('/file2.txt', 'utf8', function (err, data) {
// 使用emit抛出一个事件 read_file2
ep.emit('read_file2', data);
});
fs.readFile('/file3.txt', 'utf8', function (err, data) {
// 使用emit抛出一个事件 read_file3
ep.emit('read_file3', data);
});
上面的例子,我们使用emit()方法抛出了三个不同的事件,然后使用all()方法统一接收处理
但是类似这样的例子,其实我们可以抛出三个相同的事件,看下面的例子
emit()方法、after()方法
var fs = require('fs');
var EventProxy = require('eventproxy');
var ep = new EventProxy();
// after()接收一个事件集,对相同事件进行处理,接收三个参数:
// 第一个参数:事件名
// 第二个参数:接收这个事件几次
// 第三个参数:接收这个事件传递过来的数据的数组
ep.after('read_file', 3, function (results) {
var s = '';
for (let data of result) {
s += data;
}
console.log(s);
});
// 抛出同一事件 read_file
fs.readFile('/file1.txt', 'utf8', function (err, data) {
ep.emit('read_file', data);
});
fs.readFile('/file2.txt', 'utf8', function (err, data) {
ep.emit('read_file', data);
});
fs.readFile('/file3.txt', 'utf8', function (err, data) {
ep.emit('read_file', data);
});
fail()方法
var fs = require('fs');
var EventProxy = require('eventproxy');
var ep = new EventProxy();
// fail()方法接收error事件,使用回调函数接收error事件携带的参数
ep.fail(function (err) {
console.log(err);
});
// 不存在file4.txt文件
fs.readFile('/file4.txt', 'utf8', function (err, data) {
if (err) {
ep.emit('error', err);
}
});
throw()方法
var fs = require('fs');
var EventProxy = require('eventproxy');
var ep = new EventProxy();
// fail()方法接收error事件,使用回调函数接收error事件携带的参数
ep.fail(function (err) {
console.log(err);
});
// 不存在file4.txt文件,可以使用throw()方法抛出错误事件
fs.readFile('/file4.txt', 'utf8', function (err, data) {
if (err) {
ep.throw(err);
}
});
done()方法
// 接收一个事件集,这个实例中只有一个事件,但是回调中接收的参数还是数组
ep.after('read_file', 1, function (results) {
});
// done()方法时下面注释掉的代码中回调方法的简写
// done()方法其实就是一个语法糖,背后逻辑就是抛出一个事件,并把回调的data数据携带
fs.readFile('/file1.txt', 'utf8', ep.done('read_file'));
/*
fs.readFile('/file1.txt', 'utf8', function (err, data) {
ep.emit('read_file', data);
});
*/
done()方法还可以指定抛出, 可以对数据进行处理
fs.readFile('/file1.txt', 'utf8', ep.done('read_file', function (data) {
console.log(data + 'xxoo');
}));
原文链接:http://www.mi360.cn/articles/37
javascript中alert是Bom中的成员函数,alert对话框是模态的,具有阻塞性质的,不点击是不会执行后续代码的。js的阻塞是指在调用结果返回之前,当前线程会被挂起, 只有在得到结果之后才会继续执行。
如何优化async代码?更好的编写async函数:使用return Promise.reject()在async函数中抛出异常,让相互之间没有依赖关系的异步函数同时执行,不要在循环的回调中/for、while循环中使用await,用map来代替它
Javascript语言的执行环境是单线程,异步模式非常重要。在浏览器端,耗时很长的操作都应该异步执行,避免浏览器失去响应,最好的例子就是Ajax操作。
js异步加载又被称为非阻塞加载,浏览器在下载JS的同时,还会进行后续页面处理。那么如何实现js异步加载呢?下面整理了多种实现方案供大家参考。异步加载js方案:Script Dom Element、onload时的异步加载、$(document).ready()、async属性、defer属性、es6模块type=module属性
回调函数方式:将异步方法如readFile封装到一个自定义函数中,通过将异步方法得到的结果传给自定义方法的回调函数参数。事件驱动方式:使用node events模块,利用其EventEmitter对象
JavaScript引擎是基于单线程 (Single-threaded) 事件循环的概念构建的,同一时刻只允许一个代码块在执行,所以需要跟踪即将运行的代码,那些代码被放在一个任务队列 (job queue) 中
传统的异步解决方案采用回调函数和事件监听的方式,而这里主要记录两种异步编程的新方案:ES6的新语法Promise;ES2017引入的async函数;Generator函数(略)
JS本身是一门单线程的语言,所以在执行一些需要等待的任务(eg.等待服务器响应,等待用户输入等)时就会阻塞其他代码。如果在浏览器中JS线程阻塞了,浏览器可能会失去响应,从而造成不好的用户体验。
请实现如下的函数,可以批量请求数据,所有的URL地址在urls参数中,同时可以通过max参数 控制请求的并发度。当所有的请求结束后,需要执行callback回调。发请求的函数可以直接使用fetch。
将setState()认为是一次请求而不是一次立即执行更新组件的命令。为了更为可观的性能,React可能会推迟它,稍后会一次性更新这些组件。React不会保证在setState之后,能够立刻拿到改变的结果。
内容以共享、参考、研究为目的,不存在任何商业目的。其版权属原作者所有,如有侵权或违规,请与小编联系!情况属实本人将予以删除!