5

我最近看到了一些看起来像这样的代码:

myFunc(args).then(function() { ... });

我发现这个回调语法非常优雅。我的理解是这不是 vanilla JS 的一部分,我希望能够在不依赖特定库的情况下偶尔使用它,所以我对如何自己实现它感兴趣。那么,这种事情是如何工作的,你将如何为函数调用实现它?

4

1 回答 1

4

这种模式称为“承诺”。它由 jQuery 和 dojo 等实现,一种方法是查看他们的代码,看看他们是如何实现的。

一般的实现模式是创建一个函数,该函数返回一个对象,该对象包括一个函数(然后)将一对函数作为回调传递给前一个方法,然后在成功或失败时运行该方法。MSDN 在此处的博客文章中提供了有关承诺的更多信息

在 gitHub 上发布了一个极简实现:Promises GIST

function Promise () {
    this._thens = [];
}

Promise.prototype = {

    /* This is the "front end" API. */

    // then(onResolve, onReject): Code waiting for this promise uses the
    // then() method to be notified when the promise is complete. There
    // are two completion callbacks: onReject and onResolve. A more
    // robust promise implementation will also have an onProgress handler.
    then: function (onResolve, onReject) {
        // capture calls to then()
        this._thens.push({ resolve: onResolve, reject: onReject });
    },

    // Some promise implementations also have a cancel() front end API that
    // calls all of the onReject() callbacks (aka a "cancelable promise").
    // cancel: function (reason) {},

    /* This is the "back end" API. */

    // resolve(resolvedValue): The resolve() method is called when a promise
    // is resolved (duh). The resolved value (if any) is passed by the resolver
    // to this method. All waiting onResolve callbacks are called
    // and any future ones are, too, each being passed the resolved value.
    resolve: function (val) { this._complete('resolve', val); },

    // reject(exception): The reject() method is called when a promise cannot
    // be resolved. Typically, you'd pass an exception as the single parameter,
    // but any other argument, including none at all, is acceptable.
    // All waiting and all future onReject callbacks are called when reject()
    // is called and are passed the exception parameter.
    reject: function (ex) { this._complete('reject', ex); },

    // Some promises may have a progress handler. The back end API to signal a
    // progress "event" has a single parameter. The contents of this parameter
    // could be just about anything and is specific to your implementation.
    // progress: function (data) {},

    /* "Private" methods. */

    _complete: function (which, arg) {
        // switch over to sync then()
        this.then = which === 'resolve' ?
            function (resolve, reject) { resolve(arg); } :
            function (resolve, reject) { reject(arg); };
        // disallow multiple calls to resolve or reject
        this.resolve = this.reject = 
            function () { throw new Error('Promise already completed.'); };
        // complete all waiting (async) then()s
        var aThen, i = 0;
        while (aThen = this._thens[i++]) { aThen[which] && aThen[which](arg); }
        delete this._thens;
    }

};

(请注意,这不是我的代码。我查看了它,它作为一个起点看起来不错,但所有功劳归原作者所有)

于 2013-02-10T02:52:29.783 回答