理解javascript async的用法

发布时间 - 2026-01-11 02:54:46    点击率:

写在前面

本文将要实现一个顺序读取文件的最优方法,实现方式从最古老的回调方式到目前的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很多语言中都有,本质上是协程,下面就来看一下协程,线程,进程的区别与联系:

  • 进程:操作系统中分配资源的基本单位
  • 线程:操作系统中调度资源的基本单位
  • 协程:比线程更小的的执行单元,自带cpu上下文,一个协程一个栈

一个进程中可能存在多个线程,一个线程中可能存在多个协程,进程、线程的切换由操作系统控制,而协程的切换由程序员自身控制。异步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特性  # 回调  # 转换为  # 多个  # 很简单  # 那就是  # 操作系统  # 转化为  # 递归  # 可以利用  # 的是  # 都是  # 都有  # 很好  # 放在  # 也会  # 出了  # 让他  # 就好  # 两种  # 其他的 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: Linux安全能力提升路径_长期防护思维说明【指导】  Android okhttputils现在进度显示实例代码  Laravel如何处理JSON字段_Eloquent原生JSON字段类型操作教程  Laravel如何使用Service Container和依赖注入?(代码示例)  Laravel如何使用Contracts(契约)进行编程_Laravel契约接口与依赖反转  英语简历制作免费网站推荐,如何将简历翻译成英文?  Laravel如何与Vue.js集成_Laravel + Vue前后端分离项目搭建指南  Python面向对象测试方法_mock解析【教程】  如何破解联通资金短缺导致的基站建设难题?  微信小程序 配置文件详细介绍  Windows10电脑怎么查看硬盘通电时间_Win10使用工具检测磁盘健康  微信小程序 闭包写法详细介绍  Laravel怎么使用Intervention Image库处理图片上传和缩放  国美网站制作流程,国美电器蒸汽鍋怎么用官方网站?  如何续费美橙建站之星域名及服务?  简历在线制作网站免费版,如何创建个人简历?  惠州网站建设制作推广,惠州市华视达文化传媒有限公司怎么样?  详解Oracle修改字段类型方法总结  如何在阿里云虚拟主机上快速搭建个人网站?  Laravel如何使用Blade模板引擎?(完整语法和示例)  Android仿QQ列表左滑删除操作  高防网站服务器:DDoS防御与BGP线路的AI智能防护方案  php嵌入式断网后怎么恢复_php检测网络重连并恢复硬件控制【操作】  怎么用AI帮你设计一套个性化的手机App图标?  重庆市网站制作公司,重庆招聘网站哪个好?  浅谈Javascript中的Label语句  rsync同步时出现rsync: failed to set times on “xxxx”: Operation not permitted  微信公众帐号开发教程之图文消息全攻略  Laravel怎么实现验证码功能_Laravel集成验证码库防止机器人注册  Microsoft Edge如何解决网页加载问题 Edge浏览器加载问题修复  Laravel distinct去重查询_Laravel Eloquent去重方法  美食网站链接制作教程视频,哪个教做美食的网站比较专业点?  mc皮肤壁纸制作器,苹果平板怎么设置自己想要的壁纸我的世界?  Laravel如何集成微信支付SDK_Laravel使用yansongda-pay实现扫码支付【实战】  UC浏览器如何设置启动页 UC浏览器启动页设置方法  齐河建站公司:营销型网站建设与SEO优化双核驱动策略  如何在香港服务器上快速搭建免备案网站?  个人摄影网站制作流程,摄影爱好者都去什么网站?  Laravel如何配置.env文件管理环境变量_Laravel环境变量使用与安全管理  Windows10如何更改计算机工作组_Win10系统属性修改Workgroup  JavaScript如何实现继承_有哪些常用方法  在centOS 7安装mysql 5.7的详细教程  网站制作免费,什么网站能看正片电影?  Laravel如何使用Service Provider注册服务_Laravel服务提供者配置与加载  如何在云服务器上快速搭建个人网站?  Laravel辅助函数有哪些_Laravel Helpers常用助手函数大全  node.js报错:Cannot find module 'ejs'的解决办法  js实现获取鼠标当前的位置  ChatGPT常用指令模板大全 新手快速上手的万能Prompt合集  简单实现Android文件上传