javascript - 重新进入安全的异步函数执行

Question

我有一个saveAsync可以从应用程序的其他几个部分调用的方法。其中一些代码路径并非源自主 UI 线程，而是源自其他异步操作，例如从套接字/文件读取数据。

在我的saveAsync我调用的函数 WinRT的StorageFile流写入功能。一次只允许一名文件写入者。所以我必须对我的 saveAsync 进行多次连续调用排队功能并按顺序执行它们。这是我现在使用的代码:

SaveableMixin = {
  savesPending: 0,
  saveAsync: function() {
    self = this
    logger.debug("Save requested (_cachedFile=" + self._cachedFile + ")");
    if (self.saving) {
      self.savesPending += 1;
      logger.debug("saveAsync: already saving, " + self.savesPending + " pending now");
      return self.saving;
    }
    return self.saving = getFileNameAsync(self.serialNumber).then(function(file) {
      logger.debug("saveAsync: saving...");
      return self.node.ownerDocument.saveToFileAsync(file);
    }).then(null, (function(error) {
      return logger.error("saveAsync: failed but " + self.savesPending + " saves pending - good luck!", error);
    }).then((function() {
      logger.debug("saveAsync: saved and " + self.savesPending + " pending");
      self.saving = null;
      if (self.savesPending) {
        self.savesPending = 0;
        return self.saveAsync();
      }
    });
  }
}

CoffeeScript原始代码:

savesPending: 0
saveAsync: () ->
  logger.debug("Save requested (_cachedFile=#{@_cachedFile})")
  if @saving
    @savesPending += 1
    logger.debug("saveAsync: already saving, #{@savesPending} pending now")
    return @saving
  @saving = getCachedFile(@serialNumber)
  .then (file) =>
    logger.debug("saveAsync: saving...")
    @node.ownerDocument.saveToFileAsync(file)
  .then null, (error) =>
    logger.error("saveAsync: failed with inspection #{@serialNumber} but #{@savesPending} saves pending - good luck!", error)
  .then =>
    logger.debug("saveAsync: saved and #{@savesPending} pending")
    @saving = null
    if @savesPending
      @savesPending = 0
      return @saveAsync()

如你所见，我记得最后一个 saving promise 知道某个操作正在运行。然而，有可能我仍然得到 Access Denied异常原因不知何故，某些代码路径设法同时看到 saving由于是空的，因此现在考虑保存操作正在进行中。当变量即将分配给第一个调用者时，当第二个异步操作(例如套接字读取)完成并且还调用 saveAsync 时，似乎会发生这种情况。而第一个调用者得到 saving变量已赋值。

在 C++ 中，我会使用锁来防止这种情况发生。在 JavaScript 世界里可以做什么？

更新

_saving: WinJS.Promise.as(),
_saves: 0,
saveAsync: function() {
    var currentSave;
    currentSave = this._saves;
    this._saves += 1;
    return this._saving = this._saving.then((function(_this) {
      return function() {
        logger.debug("saveAsync: get file for save " + currentSave);
        return getCachedFile(_this.serialNumber);
      };
    })(this)).then((function(_this) {
      return function(file) {
        logger.debug("saveAsync: got file for save " + currentSave + " ...");
        return _this.node.ownerDocument.saveToFileAsync(file);
      };
    })(this)).then(null, function(error) {
      logger.debug("saveAsync: error for " + currentSave);
    });

这会在调试器中产生以下输出:

2014-12-07 23:46:52,286 - [inspection - DEBUG] - saveAsync: get file for save 0
2014-12-07 23:46:52,289 - [inspection - DEBUG] - saveAsync: get file for save 0
2014-12-07 23:46:52,349 - [inspection - DEBUG] - saveAsync: got file for save 0 ...
2014-12-07 23:46:52,444 - [inspection - DEBUG] - saveAsync: got file for save 0 ...
2014-12-07 23:46:52,446 - [inspection - DEBUG] - saveAsync: get file for save 1
2014-12-07 23:46:52,447 - [inspection - DEBUG] - saveAsync: got file for save 1 ...

当然，这是对相关文件的双重访问，并且会导致 AV 崩溃。

Answer 1

在 JavaScript 世界中，您可以使用 Promise 来做到这一点，Promise 抽象了一系列异步操作，您可以将其用作队列。

SaveableMixin = {
  queue: WinJS.promise.as(), // empty start of queue
  saveAsync: function() {
    this.queue = this.queue.then(function(){ // update the queue
      return getFileNameAsync(self.serialNumber).then(function(file) {
          logger.debug("saveAsync: saving...");
          return self.node.ownerDocument.saveToFileAsync(file);
    })..then(null, (function(error) {
      return logger.error("saveAsync: failed good luck!", error);
    }).then((function() {
      logger.debug("saveAsync: saved and " + self.savesPending + " pending");
    });
  }
}