Angular$q Service-限制promise数组的并发

Question

可能有助于为这个问题提供一点背景上下文：我正在构建一个角服务，它有助于将多部分表单数据（mp4视频）块上传到云中的存储服务。

我试图限制同时发生的未解决promise（PUTchunk data请求）的数量。我使用的是$q.all（myArrayOfPromises）。然后（）侦听正在解析的所有区块上载promise，然后在发生这种情况时返回异步调用（POST以完成文件）。我认为我的算法遇到了竞争条件，因为$q.all（）在为具有大量块的文件安排所有作业之前被调用，但在较小的文件中成功调用。

这是我的算法。

var uploadInChunks = function (file) {
   var chunkPromises = [];
   var chunkSize = constants.CHUNK_SIZE_IN_BYTES;
   var maxConcurrentChunks = 8;
   var startIndex = 0, chunkIndex = 0;
   var endIndex = chunkSize;
   var totalChunks = Math.ceil(file.size / chunkSize);
   var activePromises = 0;

   var queueChunks = function () {
      while (activePromises <= maxConcurrentChunks && chunkIndex < totalChunks) {
         var deferred = $q.defer();
         chunkCancelers.push(deferred); // array with broader scope I can use to cancel uploads as they're happening

         var fileSlice = file.slice(startIndex, Math.min(endIndex, file.size));

         chunkPromises.push(addChunkWithRetry(webUpload, chunkIndex, fileSlice).then(function () {
           activePromises--;
           queueChunks();
        });

        activePromises++;
        startIndex += chunkSize;
        endIndex += chunkSize;
        chunkIndex++;
     }
  }

  queueChunks();

  return $q.all(chunkPromises).then(function () {
     return filesApi.completeFile(file.fileId);
  });
};

尽管过早调用了$q.all，但此时仍挂起/甚至未计划的文件块最终会执行并成功解析。

我已经阅读了大量关于限制$q的并发性的书籍，并且知道有一些库可以提供帮助，但我真的很想了解为什么这不能一直起作用：）

Answer 1

您要返回的promise（$q.all）实际上并不表示您真正想要返回的promise。在上面的代码中，返回的promise将在第一个maxConcurrentChunks得到解决后完成，因为当您将其传递给$q.all（）时，chunkPromises中有多少promise。

处理此问题（并获得所需结果）的另一种方法是以下psuedocode：

var uploadInChunks = function(file){

    //...vars...
    var fileCompleteDeferral = $q.defer();

    var queueChunks = function(){
        chunkPromises.push(nextChunk(chunkIndex).then(function () {
            activePromises--;

            if(allChunksDone()) { //could be activePromises == 0, or chunkIndex == totalChunks - 1
                fileCompleteDeferral.resolve();
            }
            else {
                queueChunks();
            }
        });
    }

    return fileCompleteDeferral.promise.then(completeFile());
}

此代码返回的promise只有在完成所有promise后才能解析，而不仅仅是前8个promise。