写在前面

本文将要实现一个顺序读取文件的最优方法,实现方式从最古老的回调方式到目前的async,也会与大家分享下本人对于thunk库与co库的理解。实现的效果:顺序读取出a.txt与b.txt,将读出的内容拼接成为一个字符串。
同步读取
const readTwoFile = () => {
const f1 = fs.readFileSync('./a.txt'),
f2 = fs.readFileSync('./b.txt');
return Buffer.concat([f1, f2]).toString();
};
这种方式最利于我们理解,代码也很清楚,没有过多的嵌套,很好的维护,但是这种有着最大的问题,那就是性能,node所倡导的就是异步i/o来处理密集i/o,而同步的读取,很大的程度上浪费着服务器的cpu,这种方式的弊端明显的大于好处,所以直接pass掉。(其实node的任何异步编程的解决方案的目标都是要达到同步的语义,异步的执行。)
利用回调读取
const readTwoFile = () => {
let str = null;
fs.readFile('./a.txt', (err, data) => {
if (err) throw new Error(err);
str = data;
fs.readFile('./b.txt', (err, data) => {
if (err) throw new Error(err);
str = Buffer.concat([str, data]).toString();
});
});
};
利用回调的方式,实现起来很简单,直接的嵌套下去就好,但是这种情况下很容易造成的就是不易维护,难以读懂的情况,最为极致的情况的就是回调地狱。
Promise实现
const readFile = file =>
new Promise((reslove, reject) => {
fs.readFile(file, (err, data) => {
if (err) reject(err);
reslove(data);
});
});
const readTwoFile = () => {
let bf = null;
readFile('./a.txt')
.then(
data => {
bf = data;
return readFile('./b.txt');
},
err => { throw new Error(err) }
)
.then(
data => {
console.log(Buffer.concat([bf, data]).toString())
},
err => { throw new Error(err) }
);
};
Promise可以将横向增长的回调转化为纵向增长,能解决一些问题,但是Promise造成的问题就是代码冗余,一眼看过去,全部是then,也不是很爽,但是相比于回调函数嵌套来说,已经有了很大的提升。
yield
Generator很多语言中都有,本质上是协程,下面就来看一下协程,线程,进程的区别与联系:
一个进程中可能存在多个线程,一个线程中可能存在多个协程,进程、线程的切换由操作系统控制,而协程的切换由程序员自身控制。异步i/o利用回调的方式来应对i/o密集,同样的使用协程也可以来应对,协程的切换并没有很大的资源浪费,将一个i/o操作写成一个协程,这样进行i/o时可以吧cpu让给其他协程。
js同样支持协程,那就是yield。使用yield给我们直观的感受就是,执行到了这个地方停了下来,其他的代码继续跑,到你想让他继续执行了,他就是会继续执行。
function *readTwoFile() {
const f1 = yield readFile('./a.txt');
const f2 = yield readFile('./b.txt');
return Buffer.concat([f1, f2]).toString();
}
yield下的顺序读取呈现的也是一种顺序读取的方式,对于readFile来看有两种不同的实现方式,
利用thunkify
const thunkify = (fn, ctx) => (...items) => (done) => {
ctx = ctx || null;
let called = false;
items.push((...args) => {
if (called) return void 0;
called = true;
done.apply(ctx, args);
});
try {
fn.apply(ctx, items);
} catch(err) {
done(err);
}
};
thunkify函数就是一种柯里化得思想,最后的传入参数done就为回调函数,利用thunkify可以很轻松的实现yield函数的自动化流程:
const run = fn => {
const gen = fn();
let res;
(function next(err, data) {
let g = gen.next(data);
if (g.done) return void 0;
g.value(next);
})();
};
利用Promise
const readFile = file =>
new Promise((reslove, reject) => {
fs.readFile(file, (err, data) => {
if (err) reject(err);
reslove(data);
});
});
const run = fn => {
const gen = fn();
let str = null;
(function next(err, data) {
let res = gen.next(data);
if (res.done) return void 0;
res.value.then(
data => {
next(null, data);
},
err => { throw new Error(err); }
);
})();
};
run(readTwoFile);
上面两种方式都可以达到自动执行yield的过程,那么有没有一种方式,可以兼容这两种实现方式呢,tj大神又给出了一个库,那就是co库,先来看下用法:
// readTwoFile的实现与上面类似,readFile既可以利用Promise也可以利用thunkify // co库返回一个Promise对象 co(readTwoFile).then(data => console.log(data));
来看下co库的实现,co库默认会返回一个Promise对象,对于yield之后的值(如上面的res.value),co库会将其转换为一个Promise。实现思想很简单,基本还是利用递归的方式,大体的思路如下:
const baseHandle = handle => res => {
let ret;
try {
ret = gen[handle](res);
} catch(e) {
reject(e);
}
next(ret);
};
function co(gen) {
const ctx = this,
args = Array.prototype.slice.call(arguments, 1);
return new Promise((reslove, reject) => {
if (typeof gen === 'function') gen = gen.apply(ctx, args);
if (!gen || typeof gen.next !== 'function') return resolve(gen);
const onFulfilled = baseHandle('next'),
onRejected = baseHandle('throw');
onFulfilled();
function next(ret) {
if (ret.done) reslove(ret.value);
// 将yield的返回值转换为Proimse
const value = toPromise.call(ctx, ret.value);
if (value && isPromise(value)) return value.then(onFulfilled, onRejected);
return onRejected(new TypeError('yield type error'));
}
});
}
toPromise就是将一些类型转换为Promise,从这里我们可以看出的是可以将哪些类型放在yield后面,这里就来看一个常用的:
// 把thunkify之后的函数转化为Promise的形式
function thunkToPromise(fn) {
const ctx = this;
return new Promise(function (resolve, reject) {
fn.call(ctx, function (err, res) {
if (err) return reject(err);
if (arguments.length > 2) res = slice.call(arguments, 1);
resolve(res);
});
});
}
最近Node已经支持了async/await,可以利用其来做异步操作:
终极解决
const readFile = file =>
new Promise((reslove, reject) => {
fs.readFile(file, (err, data) => {
if (err) reject(err);
reslove(data);
});
});
const readTwoFile = async function() {
const f1 = await readFile('./a.txt');
const f2 = await readFile('./b.txt');
return Buffer.concat([f1, f2]).toString();
};
readTwoFile().then(data => {
console.log(data);
});
async/await做的就是将Promise对象给串联起来,避免了then的调用方式,代码非常的易读,就是一种同步的方式。不再需要借助其他外界类库(比如co库)就可以优雅的解决回调的问题。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
# javascript
# async
# JavaScript中使用Async实现异步控制
# Javascript中的async awai的用法
# async/await与promise(nodejs中的异步操作问题)
# JavaScript无阻塞加载和defer、async详解
# JavaScript中的await/async的作用和用法
# 关于Javascript中defer和async的区别总结
# JS中script标签defer和async属性的区别详解
# 浏览器环境下JavaScript脚本加载与执行探析之defer与async特性
# 回调
# 转换为
# 多个
# 很简单
# 那就是
# 操作系统
# 转化为
# 递归
# 可以利用
# 的是
# 都是
# 都有
# 很好
# 放在
# 也会
# 出了
# 让他
# 就好
# 两种
# 其他的
相关文章:
建站三合一如何选?哪家性价比更高?
建站之星后台管理系统如何操作?
免费网站制作appp,免费制作app哪个平台好?
c++如何打印函数堆栈信息_c++ backtrace函数与符号名解析【方法】
婚礼视频制作网站,学习*后期制作的网站有哪些?
重庆市网站制作公司,重庆招聘网站哪个好?
郑州企业网站制作公司,郑州招聘网站有哪些?
如何用IIS7快速搭建并优化网站站点?
网站建设制作、微信公众号,公明人民医院怎么在网上预约?
Android使用GridView实现日历的简单功能
Avalonia如何实现跨窗口通信 Avalonia窗口间数据传递
兔展官网 在线制作,怎样制作微信请帖?
美食网站链接制作教程视频,哪个教做美食的网站比较专业点?
建站IDE高效指南:快速搭建+SEO优化+自适应模板全解析
如何通过虚拟机搭建网站?详细步骤解析
如何选择域名并搭建高效网站?
香港服务器网站搭建教程-电商部署、配置优化与安全稳定指南
建站之星如何通过成品分离优化网站效率?
网页设计与网站制作内容,怎样注册网站?
用v-html解决Vue.js渲染中html标签不被解析的问题
大学网站设计制作软件有哪些,如何将网站制作成自己app?
如何用花生壳三步快速搭建专属网站?
家族网站制作贴纸教程视频,用豆子做粘帖画怎么制作?
如何选择适配移动端的WAP自助建站平台?
在线流程图制作网站手机版,谁能推荐几个好的CG原画资源网站么?
全景视频制作网站有哪些,全景图怎么做成网页?
如何用AWS免费套餐快速搭建高效网站?
如何在阿里云域名上完成建站全流程?
如何在阿里云高效完成企业建站全流程?
高配服务器限时抢购:企业级配置与回收服务一站式优惠方案
网站视频制作书签怎么做,ie浏览器怎么将网站固定在书签工具栏?
网站制作新手教程,新手建设一个网站需要注意些什么?
建站之星代理如何获取技术支持?
网站制作难吗安全吗,做一个网站需要多久时间?
定制建站如何定义?其核心优势是什么?
如何在Golang中指定模块版本_使用go.mod控制版本号
如何正确下载安装西数主机建站助手?
建站之星会员如何解锁更多建站功能?
建站之家VIP精选网站模板与SEO优化教程整合指南
模具网站制作流程,如何找模具客户?
广州网站制作的公司,现在专门做网站的公司有没有哪几家是比较好的,性价比高,模板也多的?
c# 服务器GC和工作站GC的区别和设置
建站之星五站合一营销型网站搭建攻略,流量入口全覆盖优化指南
建站之星下载版如何获取与安装?
建站之星代理平台如何选择最佳方案?
建站之星与建站宝盒如何选择最佳方案?
临沂网站制作公司有哪些,临沂第四中学官网?
广州网站制作公司哪家好一点,广州欧莱雅百库网络科技有限公司官网?
制作证书网站有哪些,全国城建培训中心证书查询官网?
建站之星CMS五站合一模板配置与SEO优化指南
*请认真填写需求信息,我们会在24小时内与您取得联系。