天天看点

promisify在node中源码实现

我们都知道在node中提供的API可以分为同步实现和异步实现。但是同步一般会阻塞线程,所以我么会选择异步实现。通过实践我们知道node提供的异步API格式都是类似的,如果我们能像使用Promise一样调用node的API,岂不美哉。在node V12之后官方已经为我们实现了相关设计。今天我们就一步步来理解它的真相,并手动实现promisify。

基于回调实现

const fs = require('fs');


fs.readFile('./name.txt','utf8',(err,data)=>{
    if(err) throw err;
    console.log(data)
   })
           

官方Promise化

const fs = require('fs').promises;
fs.readFile('name.txt','utf8').then(data=>{
    console.log(data)
}).catch(err=>{
    console.log(err)
})


// 调试信息 低于v12下会有警告信息
[Running] node "f:\web全栈\js\异步编程\tempCodeRunnerFile.js"
(node:3372) ExperimentalWarning: The fs.promises API is experimental
age.txt

[Done] exited with code=0 in 0.396 seconds
           

手动实现promisify(柯里化)

// 1.高阶函数
// 2.返回一个Promise,后续可以.then操作


const promisify = fn => (...args) => new Promise((resolve,reject)=>{
    fn(...args,(err,data)=>{
        if(err) reject(err);
        resolve(data);
    })
})

// 使用如下
const fs = require('fs');
const read = promisify(fs.readFile);
read('name.txt','utf8').then(data=>{
    console.log(data)
})
// 调试结果
[Running] node "f:\web全栈\js\异步编程\tempCodeRunnerFile.js"
age.txt

[Done] exited with code=0 in 0.244 seconds
           

这就是node中promisify的实现方式,其实还是很好理解的。