再谈 JavaScript 异步编程

2019年8月26日 156次阅读 来源: Dolphin_Wood

跟着前端的生长，异步这个词真是愈来愈罕见了。假定我们如今有这么一个异步使命：

向服务器提议数次要求，每次要求的效果作为下次要求的参数。

来看看我们都有哪些处置惩罚要领：

Callbacks

最早想到也是最经常运用的就是回调函数了，我们来举行简朴的封装：

javascriptlet makeAjaxCall = (url, cb) => {
    // do some ajax
    // callback with result
}

makeAjaxCall('http://url1', (result) => {
    result = JSON.parse(result)
})

嗯，看起来还不错！然则当我们尝试嵌套多个使命时，代码看起来会是如许的：

javascriptmakeAjaxCall('http://url1', (result) => {
    result = JSON.parse(result)

    makeAjaxCall(`http://url2?q=${result.query}`, (result) => {
        result = JSON.parse(result)

        makeAjaxCall(`http://url3?q=${result.query}`, (result) => {
            // ...
        })
    })
})

天哪！快让那堆 }) 见鬼去吧！

因而，我们想尝试借助 JavaScript 事宜模子：

Pub/Sub

在 DOM 事宜的处置惩罚中，Pub/Sub 是一种很罕见的机制，比方我们要为元素加上事宜监听：

javascriptelem.addEventListener(type, (evt) => {
    // handler
})

所以我们是否是也能够组织一个相似的模子来处置惩罚异步使命呢？

首先是要构建一个分发中间，并增加 on / emit 要领：

javascriptlet PubSub = {
    events: {},
    on(type, handler) {
        let events = this.events
        events[type] = events[type] || []
        events[type].push(handler)
    },
    emit(type, ...datas) {
        let events = this.events

        if (!events[type]) {
            return
        }

        events[type].forEach((handler) => handler(...datas))
    }
}

然后我们便能够如许运用：

javascriptconst urls = [
    'http://url1',
    'http://url2',
    'http://url3'
]

let makeAjaxCall = (url) => {
    // do some ajax
    PubSub.emit('ajaxEnd', result)
}

let subscribe = (urls) => {
    let index = 0

    PubSub.on('ajaxEnd', (result) => {
        result = JSON.parse(result)

        if (urls[++index]) {
            makeAjaxCall(`${urls[index]}?q=${result.query}`)
        }
    })

    makeAjaxCall(urls[0])
}

嗯……比起回调函数彷佛没有什么革命性的转变，然则如许做的优点是：我们能够将要乞降处置惩罚函数放在差别的模块中，削减耦合。

Promise

真正带来革命性转变的是 Promise 范例[1]。借助 Promise，我们能够如许完成异步使命：

javascriptlet makeAjaxCall = (url) => {
    return new Promise((resolve, reject) => {
        // do some ajax
        resolve(result)
    })
}

makeAjaxCall('http://url1')
    .then(JSON.parse)
    .then((result) => makeAjaxCall(`http://url2?q=${result.query}`))
    .then(JSON.parse)
    .then((result) => makeAjaxCall(`http://url3?q=${result.query}`))

好棒！写起来像同步处置惩罚的函数一样！

别着急，少年。我们另有更棒的：

Generators

ES6 的别的一个大杀器就是 Generators[2]。在一个 generator function 中，我们能够经由历程 yield 语句来中缀函数的实行，并在函数外部经由历程 next 要领来迭代语句，更主要的是我们能够经由历程 next 要领向函数内部注入数据，动态转变函数的行动。比方：

javascriptfunction* gen() {
    let a = yield 1
    let b = yield a * 2
    return b
}

let it = gen()

it.next() // output: {value: 1, done: false}
it.next(10) // a = 10, output: {value: 20, done: false}
it.next(100) // b = 100, output: {value: 100, done: true}

经由历程 generator 将我们之前的 makeAjaxCall 函数举行封装：

javascriptlet makeAjaxCall = (url) => {
    // do some ajax
    iterator.next(result)
}

function* requests() {
    let result = yield makeAjaxCall('http://url1')
    result = JSON.parse(result)
    result = yield makeAjaxCall(`http://url2?q=${result.query}`)
    result = JSON.parse(result)
    result = yield makeAjaxCall(`http://url3?q=${result.query}`)
}

let iterator = requests()
iterator.next() // get everything start

哦！看起来逻辑很清晰的模样，然则每次都得从外部注入 iterator 觉得好不惬意……

别急，我们让 Promise 和 Generator 夹杂一下，看会产出什么黑魔法：

javascriptlet makeAjaxCall = (url) => {
    return new Promise((resolve, reject) => {
        // do some ajax
        resolve(result)
    })
}

let runGen = (gen) => {  
    let it = gen()

    let continuer = (value, err) => {
        let ret

        try {
            ret = err ? it.throw(err) : it.next(value)
        } catch (e) {
            return Promise.reject(e)
        }

        if (ret.done) {
            return ret.value
        }

        return Promise
            .resolve(ret.value)
            .then(continuer)
            .catch((e) => continuer(null, e))
    }

    return continuer()
}

function* requests() {
    let result = yield makeAjaxCall('http://url1')
    result = JSON.parse(result)
    result = yield makeAjaxCall(`http://url2?q=${result.query}`)
    result = JSON.parse(result)
    result = yield makeAjaxCall(`http://url3?q=${result.query}`)
}

runGen(requests)

runGen 函数看起来像个自动机一样，好厉害！

实际上，这个 runGen 的要领是对 ECMAScript 7 async function 的一个完成：

async function

ES7 中，引入了一个更天然的特征 async function[3]。应用 async function 我们能够如许完成使命：

javascriptlet makeAjaxCall = (url) => {
    return new Promise((resolve, reject) => {
        // do some ajax
        resolve(result)
    })
}

;(async () => {
    let result = await makeAjaxCall('http://url1')
    result = JSON.parse(result)
    result = await makeAjaxCall(`http://url2?q=${result.query}`)
    result = JSON.parse(result)
    result = await makeAjaxCall(`http://url3?q=${result.query}`)
})()

就像我们在上文把 Promise 和 Generator 连系在一起时一样，await 症结字后一样接收一个 Promise。在 async function 中，只要在 await 后的语句完成后剩下的语句才会被实行，全部历程就像我们用 runGen 函数封装 Generator 一样。

总结

以上就是笔者总结的几种 JavaScript 异步编程形式。在行文历程当中，我们只是简朴形貌了这几种形式，并没有说起错误处置惩罚的历程，您如果对此感兴趣，能够参考下文列出的援用文章。

（全文完）

参考资料

  1. Promises/A+ Specification
  2. Going Async With ES6 Generators
  3. ES7 async functions
  4. Simplifying Asynchronous Coding with ES7 Async Functions
  5. 从第三方完成看 Promise

重编自我的博客，原文地点：https://idiotwu.me/going-async-with-javascript/

    原文作者：Dolphin_Wood
    原文地址: https://segmentfault.com/a/1190000002881997
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞