ES6中的异步编程：Generators函数（一）

时间 2019-12-06

标签 es6 异步编程 generators 函数栏目 JavaScript 繁體版

原文原文链接

对ES6的generators的介绍分为3个部分java

第一部分base介绍及使用es6
第二部分基于generators和Promise实现最强大的异步处理逻辑ajax

概述

Generator函数是协程在ES6的实现，用来作异步流程的封装，最大特色就是能够交出函数的执行权（即暂停执行）。十分的奇葩，光看语法，简直认不出这也是JavaScript了。因为可使用yield语句来暂停异步操做，这让generators异步编程的代码，很像同步数据流方法同样。由于从语法角度来看，generators函数是一个状态机，封装了多个内部状态，经过iterator来分步调用。编程

基本语法

2个关键字搞定generators语法

function与函数名直接的星号：*json
函数体内yield语句promise

function* testGenerator() {
    yield 'first yield';
    yield 'second yield';
    return 'last';
}

var gen = testGenerator();

console.log(gen.next().value);// first yield 
// { value: 'first yield', done: false }
console.log(gen.next().value);// second yield
// { value: 'second yield', done: false }
console.log(gen.next().value);// last 
// { value: 'last', done: true }

console.log(gen.next().value);// undefined

for...of遍历

for...of循环能够自动遍历generators函数的iterator对象，且再也不须要调用next方法。for...of须要检查iterator对象的done属性，若是为true，则结束循环，所以return语句不能被遍历到app

for (let i of testGenerator) {
    console.log(i);
}
// first yield
// second yield

next方法的参数

yield句自己没有返回值，或者说老是返回undefined。next方法能够带一个参数，该参数就会被看成上一个yield语句的返回值。异步

function *gen(){
  let arr = [];
  while(true){
    arr.push(yield arr);
  }
}

var name = gen();

console.log(name.next('first').value);//[]
console.log(name.next('second').value);//["second"]
console.log(name.next('thrid').value);//["second","thrid"]

须要注意的是，第一次执行next设置参数没有效果。async

generators实践

实现Fibonacci数列

递归实现：

function* fib (n, current = 0, next = 1) {
  if (n === 0) {
    return 0;
  }

  yield current;
  yield* fib(n - 1, next, current + next);
}

for (let n of fibonacci()) {
  if (n > 1000) break;
  console.log(n);
}

注：若是存储计算结果再过运算，这样的实现比递归方法效率高3倍

function* fibonacci() {
  let [prev, curr] = [0, 1];
  for (;;) {
    [prev, curr] = [curr, prev + curr];
    yield curr;
  }
}

for (let n of fibonacci()) {
  if (n > 1000) break;
  console.log(n);
}

利用for...of循环，遍历任意对象（object）的方法

原生的JavaScript对象没有遍历接口，没法使用for...of循环，经过Generator函数为它加上这个接口，就能够用了。

function* objectEntries(obj) {
  let propKeys = Reflect.ownKeys(obj);

  for (let propKey of propKeys) {
    yield [propKey, obj[propKey]];
  }
}

let jane = { first: 'Jane', last: 'Doe' };

for (let [key, value] of objectEntries(jane)) {
  console.log(`${key}: ${value}`);
}
// first: Jane
// last: Doe

ES6中iterator遍历接口汇总

for...of循环
扩展运算符（...）
解构赋值
Array.from方法内部调用的

它们均可以将Generator函数返回的Iterator对象，做为参数来使用。

function* numbers () {
  yield 1
  yield 2
  return 3
}

// 扩展运算符
[...numbers()] // [1, 2]

// Array.from 方法
Array.from(numbers()) // [1, 2]

// 解构赋值
let [x, y] = numbers();
x // 1
y // 2

// for...of 循环
for (let n of numbers()) {
  console.log(n)
}
// 1
// 2

generators与同步

generators一个特色就是代码看上去很是像同步编程的效果

function* test() {
    yield( "1st" );
    yield( "2nd" );
    yield( "3rd" );
    yield( "4th" );
}
var iterator = test();

console.log( "== Start of Line ==" );
console.log( iterator.next().value );
console.log( iterator.next().value );
for ( var line of iterator ) {
    console.log( line );
}
console.log( "== End of Line ==" );

看下输出，浓浓的同步执行风格。

== Start of Line ==
1st
2nd
3rd
4th
== End of Line ==

callback、Promises、Generators比较

举例说一个场景，查询一篇新闻文章的做者信息，流程是：请求最新文章列表->请求某文章相关id->做者id信息

callback实现

getArticleList(function(articles){
    getArticle(articles[0].id, function(article){
        getAuthor(article.authorId, function(author){
            alert(author.email);
        })
    })
})

function getAuthor(id, callback){
    $.ajax(url,{
        author: id
    }).done(function(result){
        callback(result);
    })
}

function getArticle(id, callback){
    $.ajax(url,{
        id: id
    }).done(function(result){
        callback(result);
    })
}

function getArticleList(callback){
    $.ajax(url)
    .done(function(result){
        callback(result);
    });
}

用Promise来作

getArticleList()
.then(articles => getArticle(articles[0].id))
.then(article => getAuthor(article.authorId))
.then(author => {
    alert(author.email);
});

function getAuthor(id){
    return new Promise(function(resolve, reject){
        $.ajax({
            url: id+'author.json',
            success: function(data) {
              resolve(data);
          }
        })
    });
}

function getArticle(id){
    return new Promise(function(resolve, reject){
        $.ajax({
            url: id+'.json',
            success: function(data) {
              resolve(data);
          }
        })
    });
}

function getArticleList(){
    return new Promise(function(resolve, reject){
       $.ajax({
           url: 'all.json',
           success: function(data) {
             resolve(data);
         }
       }) 
    });
}

Gererator来实现

function* run(){
  var articles = yield getArticleList();
  var article = yield getArticle(articles[0].id);
  var author = yield getAuthor(article.authorId);
  alert(author.email);  
}

var gen = run();
gen.next().value.then(function(r1){
  gen.next(r1).value.then(function(r2){
      gen.next(r2).value.then(function(r3){
        gen.next(r3);
        console.log("done");
      })
  })
});

runGenerator的实现

每次都要手动去调用next方法，仍是会让代码变得冗长，咱们能够设计一个专门用来运行generators的方法，并能够抽象出来，之后就能够作一个统一的error管理，或者获取本地数据逻辑的变化。

Thunk函数方法

编译器的‘传名调用’实现，将全部的参数放到一个临时函数中，再将这个临时函数做为参数传入到函数体中。该临时函数就叫作Thunk函数。

任何函数，只要参数有回调函数，就能写成Thunk函数的方法。下面就是简单的Thunk函数转换器。

//es5
var Thunk = function(fn) {
    return function() {
        var args = Array.pototype.silce.call(argumnets);
        return function (callback) {
            args.push(callback);
            return fn.apply(this. args);
        }
    }
}

//es6
var Thunk = function(fn) {
    return function(...args) {
        return function(callback) {
            return fn.call(this, ...args, callback);
        }
    }
}

一个使用Thunk方法来实现readFile的例子

//正常版本的readFile（多参数）
fs.readFile(filename, callback);

//Thunk版本的readFile（单参数）
var readFileThunk = Thunk(filename);
readFileThunk(callback);

var Thunk = function(fileName) {
    return function(callback) {
        return fs.readFile(fileName, callback);
    }
}

能够看到，若是咱们经过构建一个基于Thunk方法实现的runGenerators函数，能够很好的控制咱们的generators运行流程。

function *generator() {
    var articles = yield getArticleList();
    var article = yield getArticle(articles[0].id);
    var author = yield getAuthor(article.authorId);
    console.log(author.email);
}

function runGenerator() {
    var gen = generator();
    
    function go(result) {
        if(result.done) return;
        
        result.value.then(function(rsp) {
            go(gen.next(rsp));
        })
    }
    
    go(gen.next());
}

runGenerator();