【JS基础】从JavaScript中的for...of提及(下) - async和await

写在前面

本文首发于公众号:【符合预期的CoyPan】javascript

在上一篇文章中,梳理了javascript中的两个重要概念:iterator和generator,而且介绍了二者在异步操做中的应用。前端

【JS基础】从JavaScript中的for...of提及(上) - iterator 和 generatorjava

在异步操做中使用iterator和generator是一件比较费劲的事情,而ES2017给咱们提供了更为简便的async和await。node

async和await

async

mdn上说:async function 声明用于定义一个返回 AsyncFunction 对象的异步函数。异步函数是指经过事件循环异步执行的函数,它会经过一个隐式的 Promise 返回其结果。数组

简单来讲,若是你在一个函数前面使用了async关键字,那么这个函数就会返回一个promise。若是你返回的不是一个promise,JavaScript也会自动把这个值"包装"成Promise的resolve值。例如:promise

// 返回一个promise
async function aa() {
    return new Promise(resolve => {
        setTimeout(function(){
            resolve('aaaaaa');
        }, 1000);
    });
}

aa().then(res => {
    console.log(res); // 1s后输出 'aaaaaa'
});

typeof aa === 'function'; // true
Object.prototype.toString(aa) === '[object AsyncFunction]'; // true
Object.prototype.toString(aa()) === '[object Promise]'; // true



// 返回一个非promise
async function a() {
    return 1;
}
const b = a(); 
console.log(b); // Promise {<resolved>: 1}

a().then(res => {
    console.log(res); // 1
})
复制代码

async 函数抛出异常时,Promise 的 reject 方法也会传递这个异常值。例以下面的例子:babel

async function a(){
    return bbb;
}

a()
.then(res => {
    console.log(res);
})
.catch( e => {
    console.log(e); // ReferenceError: bbb is not defined
});
复制代码

await

await 操做符用于等待一个Promise 对象。它只能在异步函数 async function 中使用。await 表达式会暂停当前 async function 的执行,等待 Promise 处理完成。若 Promise 正常处理(fulfilled),其回调的resolve函数参数做为 await 表达式的值,继续执行 async function。若 Promise 处理异常(rejected),await 表达式会把 Promise 的异常缘由抛出。另外,若是 await 操做符后的表达式的值不是一个 Promise,则返回该值自己。看下面的例子:app

const p = function() {
    return new Promise(resolve => {
        setTimeout(function(){
            resolve(1);
        }, 1000);
    });
};

const fn = async function() {
    const res = await p();
    console.log(res); 
    const res2 = await 2;
    console.log(res2);
};

fn(); // 1s后,会输出1, 紧接着,会输出2


// 把await放在try catch中捕获错误
const p2 = function() {
    return new Promise(resolve => {
        console.log(ppp);
        resolve();
    });
};

const fn2 = async function() {
    try {
        await p2();
    } catch (e) {
        console.log(e); // ppp is not defined
    }
};

fn2();

复制代码

当代码执行到await语句时,会暂停执行,直到await后面的promise正常处理。这和咱们以前讲到的generator同样,可让代码在某个地方中断。只不过,在generator中,咱们须要手动写代码去执行generator,而await则是像一个自带执行器的generator。某种程度上,咱们能够理解为:await就是generator的语法糖。看下面的代码:koa

const p = function() {
    return new Promise(resolve, reject=>{
        setTimeout(function(){
            resolve(1);
        }, 1000);
    });
};

const f = async function() {
    const res = await p();
    console.log(res);
}
复制代码

咱们使用babel对这段代码进行转化,获得如下的代码:异步

function _asyncToGenerator(fn) { return function () { var gen = fn.apply(this, arguments); return new Promise(function (resolve, reject) { function step(key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { return Promise.resolve(value).then(function (value) { step("next", value); }, function (err) { step("throw", err); }); } } return step("next"); }); }; }

var p = function p() {
    return new Promise(resolve, function (reject) {
        setTimeout(function () {
            resolve(1);
        }, 1000);
    });
};

var f = function () {
    var _ref = _asyncToGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee() {
        var res;
        return regeneratorRuntime.wrap(function _callee$(_context) {
            while (1) {
                switch (_context.prev = _context.next) {
                    case 0:
                        _context.next = 2;
                        return p();

                    case 2:
                        res = _context.sent;

                        console.log(res);

                    case 4:
                    case "end":
                        return _context.stop();
                }
            }
        }, _callee, this);
    }));

    return function f() {
        return _ref.apply(this, arguments);
    };
}();
复制代码

经过变量名能够看到,babel也是将async await转换成了generator来进行处理的。

任务队列

如下的场景实际上是很常见的:

咱们有一堆任务,咱们须要按照必定的顺序执行这一堆任务,拿到最终的结果。这里,把这一堆任务称为一个任务队列。

js中的队列其实就是一个数组。

同步任务队列

任务队列中的函数都是同步函数。这种状况比较简单,咱们能够采用reduce很方便的遍历。

const fn1 = function(i) {
    return i + 1;
};
const fn2 = function(i) {
    return i * 2;
};
const fn3 = function(i) {
    return i * 100;
};
const taskList = [fn1, fn2, fn3];
let a = 1;
const res = taskList.reduce((sum, fn) => {
    sum = fn(sum);
    return sum;
}, a); 

console.log(res); // 400
复制代码

异步任务队列

任务队列中的函数都是异步函数。这里,咱们假设全部的函数都是以Promise的形式封装的。如今,须要依次执行队列中的函数。假设异步任务队列以下:

const fn1 = function() {
    return new Promise( resolve => {
        setTimeout(function(){
            console.log('fn1');
            resolve();
        }, 2000);
    });
};
const fn2 = function() {
    return new Promise( resolve => {
        setTimeout(function(){
            console.log('fn2');
            resolve();
        }, 1000);
    });
};
const fn3 = function() {
    console.log('fn3');
    return Promise.resolve(1);
};
const taskList = [fn1, fn2, fn3];
复制代码

能够使用正常的for循环或者for...of... 来遍历数组,而且使用async await来执行代码(注:不要使用forEach,forEach不支持这种场景)

// for循环
(async function(){
    for(let i = 0; i < taskList.length; i++) {
        await taskList[i]();
    }
})();

// for..of..
(async function(){
    for(let fn of taskList) {
    	await fn();
	}
})();

复制代码

koa2洋葱模型实现原理

koa2,你们都不陌生了。koa2的洋葱模型,是怎么实现的呢?先来看下面的代码:

const Koa = require('koa');
const app = new Koa();

// logger

app.use(async (ctx, next) => {
  console.log(1);
  await next();
  console.log(2);
  const rt = ctx.response.get('X-Response-Time');
  console.log(`${ctx.method} ${ctx.url} - ${rt}`);
});

// x-response-time

app.use(async (ctx, next) => {
  console.log(3);
  const start = Date.now();
  await next();
  console.log(4);
  const ms = Date.now() - start;
  ctx.set('X-Response-Time', `${ms}ms`);
});

// response

app.use(async ctx => {
  console.log(5);
  ctx.body = 'Hello World';
});

app.listen(3000);

// 访问node时,代码输出以下:
// 1
// 3
// 5 
// 4 
// 2
// GET / - 6ms
复制代码

其实实现起来很简单,app.use就是将全部的回调函数都塞进了一个任务队列里面,调用await next()的时候,会直接执行队列里面下一个任务,直到下一个任务执行完成,才会接着执行后续的代码。咱们来简单实现一下最基本的逻辑:

class TaskList {
    constructor(){
        this.list = [];
    }
    use(fn) {
        fn && this.list.push(fn);
    }
    start() {
        const self = this;
        let idx = -1;
        const exec = function() {
            idx++;
            const fn = self.list[idx];
            if(!fn) {
                return Promise.resolve();
            }
            return Promise.resolve(fn(exec))
        }
        exec();
    }
} 

const test1 = function() {
    return new Promise( resolve => {
        setTimeout(function(){
            console.log('fn1');
            resolve();
        }, 2000);
    });
};

const taskList = new TaskList();

taskList.use(async next => {
    console.log(1);
    await next();
    console.log(2);
});
taskList.use(async next => {
    console.log(3);
    await test1();
    await next();
    console.log(4);
});
taskList.use(async next => {
    console.log(5);
    await next();
    console.log(6);
});
taskList.use(async next => {
    console.log(7);
});
taskList.start();

// 输出: 一、三、fn一、五、七、六、四、2
复制代码

写在后面

能够看到,使用async和await进行异步操做,能够使代码看起来更为清晰,简单。咱们能够用同步代码的方式来书写异步代码。本文还探究了前端开发中很常见的任务队列的相关问题。经过本文和上一篇文章,我本身也对js中的异步操做有了更深刻,更全面的认识。符合预期。