使用 Promise 在 Javascript 中创建“原子”代码块

Question

来自 Java 背景的我现在正试图围绕 Javascript 的异步特性来思考。我在我的代码中使用 Promise 来做到这一点，直到现在一切都像一个魅力，但现在我有一个概念性问题，即使在多次阅读 Promise/A+ 规范后也没有找到明确的答案。

我的要求是：我有一个修改共享对象的方法，将更新存储在 PouchDB 中，然后再将其读回，以便从数据库中获取更新的修订 id 字段（乐观锁定）。在 Pouch 中存储和更新数据是异步的（为简洁起见，我省略了存储“this”以从 Promise 中调用方法）：

var _doc = ...;
var _pouch = new PouchDB(...);

function setValue(key, value) {
    _doc[key] = value;
    _pouch.put(_doc)
    .then(function() {
        return _pouch.get(_doc._id);
    })
    .then(function(updatedDoc) {
        _doc = updatedDoc;
    });
}

现在，我想确保在 _doc 被再次读取之前，没有在 _doc 上设置其他键。 （a）是否有可能另一个 setValue() 调用正在执行 put() （具有过时的修订 ID）而来自 Pouch 的 get() 调用尚未执行（鉴于 JS 正在使用的消息队列方法) 和 (b) 如果可能的话，以下解决方案是否安全（它在我的测试中有效，但由于我不知道我的测试是否考虑了所有可能性......；再次省略存储“this” ):

var _doc = ...;
var _pouch = new PouchDB(...);
var _updatePromise;

function setValue(key, value) {
    if (_updatePromise == null) {
        setValueInternal(key, value);
    }
    else {
        // make sure the previous setValue() call is executed completely before
        // starting another one...
        _updatePromise.then(function() {
            setValueInternal(key, value);
        });
    }
}

function setValueInternal(key, value) {
    _doc[key] = value;

    _updatePromise = new Promise(function(done, reject) {
        _pouch.put(_doc)
        .then(function() {
            return _pouch.get(_doc._id);
        })
        .then(function(updatedDoc) {
            _doc = updatedDoc;
            _updatePromise = null;
            done();
        })
        catch(function(error) {
            _updatePromise = null;
            reject(error);
        });
    });
}

我认为如果履行承诺（调用 done()）将同步调用下一个 then() 函数，它应该可以正常工作，但我无法找到明确的答案是否是这种情况。

非常感谢任何澄清，并感谢您的帮助。

Answer 1

您在这里尝试执行的链接承诺确实按预期工作，但我不相信有任何保证done 被同步调用。我认为你的代码可以工作，但你有一些反模式。我建议简化以避免明确创建承诺。

还想一想：如果您连续调用setValue 4 次，那么应该往返服务器多少次？这样做会导致需要 4 个。你想将它们分成 1 个还是 2 个？

每个setValue一个往返：

var _doc = ...;
var _pouch = new PouchDB(...);
var _updatePromise = Promise.resolve();

function setValue(key, value) {
    // make sure the previous setValue() call is executed completely before
    // starting another one...
    _updatePromise = _updatePromise.then(function() {
        _doc[key] = value;

        return _pouch.put(_doc)
        .then(function() {
            return _pouch.get(_doc._id);
        })
        .then(function(updatedDoc) {
            _doc = updatedDoc;
        });
    });
}