首页 > 其他 > 详细

asnyc await

时间:2020-03-15 23:30:00      阅读:98      评论:0      收藏:0      [点我收藏+]

一直以为es7里面的async和await可以用来简化串行异步代码,而没有想到还能并行。
说到底,这俩货不过是promise的语法糖,await的作用只是串行解析promise。
通常我们这样写:

function asyncAwaitFn(str) {
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            resolve(str)
        }, 1000);
    })
}
const parallel = async () => { //并行执行
    console.time(‘parallel‘)
    const parallelOne = await asyncAwaitFn(‘1‘);
    const parallelTwo = await asyncAwaitFn(‘2‘)
    console.log(parallelOne) //1
    console.log(parallelTwo) //2
    console.timeEnd(‘parallel‘) //2003.509033203125ms
}
parallel()

这是串行,显然最后的执行时间应该大于2000ms。

但如果换一种写法:

function asyncAwaitFn(str) {
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            resolve(str)
        }, 1000);
    })
}
const parallel = async () => { //并行执行
    console.time(‘parallel‘)
    const parallelOne = asyncAwaitFn(‘1‘);
    const parallelTwo = asyncAwaitFn(‘2‘)
    console.log(await parallelOne) //1
    console.log(await parallelTwo) //2
    console.timeEnd(‘parallel‘) //1001.87255859375ms
}
parallel()

最后执行时间只要1000ms,显然是并行了。

不过严谨来说,这依然是promise本身的并行罢了。

=====================

 

async表示函数里有异步操作,await表示紧跟在后面的表达式需要等待结果。

async函数返回一个 Promise 对象,可以使用then方法添加回调函数。当函数执行的时候,一旦遇到await就会先返回,等到异步操作完成,再接着执行函数体内后面的语句。

await 后面必须跟Promise对象,若非Promise,则不会拦截后面代码执行。当Promise对象resolve过后并且执行完then里面的代码,就执行下一步代码,不resolve则不会触发下一行代码执行,Promise对象处于pending状态

需注意:如果then()中需要异步操作,不会等then中的异步执行完过后再执行下一个then()的函数。原因就是,异步函数中,没有时间让你return值给下一个then()回调函数。解决方案是使用async函数包裹then中的回调函数,将其中的异步操作用new Promise((res, rej) => { 异步操作 })包裹,并用await等待异步操作完成。

举个例子:

const aa = _ => new Promise((res, rej) => { // 设置aa函数返回promise对象
    setTimeout(function() {
        console.log(‘1‘)
        res(‘2‘)
    }, 1000);
})
let bb = async function() {
  await aa().then((res) => { // await会等待aa()执行完,并且then代码也执行完,当然,then代码里面的异步操作不会执行。
    console.log(res)
    setTimeout(function(){  
        console.log(‘4‘) // then中的代码执行完直接进入下一个then,这个then其实return了undefined
        return ‘sdf‘
    }, 2000)
    // return ‘自定义插入‘
  }).then(res => {
      console.log(res) // undefined
  }).catch(err => {
      console.log(err)
  })
  console.log(‘3‘)
}
console.log(bb()) // Promise {<pending>}
// console结果
// Promise { <pending> }
// 1
// 2
// undefined
// 3
// 4

目标:当A异步任务完成后,继续并发n个B异步任务,使用asnyc函数实现

const fs = require(‘fs‘)
const readdir = function (path) { // 读文件函数
    return new Promise((res, rej) => {
        fs.readdir(path, (err, files) => {
            if (err) res(err)
            res(files)
        })
    })
}
const stat = function (path) { // 确认是否是文件夹
    return new Promise((res, rej) => {
        fs.stat(path, (err, file) => {
            if (err) res(err)
            file.isDirectory() ? res(‘dir‘) : res(‘file‘) // 返回类型结果
        })
    })
}
const getdirs = async function (filepath) {
    let sendFiles = []
    const files = await readdir(filepath) // 读文件夹
    const promises = files.map(function (file) { // 利用map函数特性,返回值组成新的数组,这儿并没有用async函数,map内并不等待一个stat回来后再进行另一个stat,是同时进行的。
        return stat(filepath + ‘/‘ + file)
            .then(res => {
                if (res === ‘dir‘) sendFiles.push(file)
            })
    })
    await Promise.all(promises) // 这儿是异步并发的关键,在这个位置等待所有promise对象resolve。
    // console.log(sendFiles)
    return sendFiles
}
const dir = getdirs(‘../wepy-redux-boilerplate/src/store‘)
console.log(‘>>>‘, dir) // async函数运行结果为Promise对象,使用then方法获取返回值
dir.then(v => console.log(v))

作者:吃个石头
原始链接:https://www.zhihu.com/question/41493194/answer/91299155
来源:博客园
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。


asnyc await

原文:https://www.cnblogs.com/fs0196/p/12500892.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!