如何使用q.js承诺与多个异步操作工作(how to use q.js promises to wo

2019-07-04 05:03发布

注意:这个问题也是跨张贴在Q.js邮件列表在这里 。


我曾与多个异步操作的情况和我接受的答案指出,如q.js使用承诺使用库将更为有利。

我相信重构我的代码使用承诺,但因为代码是相当长的,我已经削减了部分无关,出口的关键零部件到一个单独的回购协议。

回购协议是在这里 ,最重要的文件是这样 。

要求是,我想页面大小是遍历所有dragged'n下降文件后,非空。

问题是,getSizeSettingsFromPage函数内FileAPI操作导致getSizeSettingsFromPage是异步。

所以我不能把checkWhenReady(); 像这样。

function traverseFiles() {
  for (var i=0, l=pages.length; i<l; i++) {
    getSizeSettingsFromPage(pages[i], calculateRatio);   
  }
  checkWhenReady(); // this always returns 0.
}

这工作,但它并不理想。 我宁愿只是一次调用checkWhenReady后,所有的pages都经过了这种功能calculateRatio成功。

function calculateRatio(width, height, filename) {
  // .... code 
  pageSizes.add(filename, object);
  checkWhenReady(); // this works but it is not ideal. I prefer to call this method AFTER all the `pages` have undergone calculateRatio
  // ..... more code...
}

如何重构代码,以利用公司承诺在Q.js?

Answer 1:

与Q.js低于我的建议,得到这个工作。 关键是,任何时候你想要异步做的事,你应该返回一个承诺,一旦任务完成,你应该可以解决这一承诺。 这使得该函数的调用监听要完成的任务,然后去做别的事情。

和以前一样,我有我的评论与变化// *** 。 让我知道,如果你有任何问题。

        function traverseFiles() {
            // *** Create an array to hold our promises
            var promises = [ ];
            for (var i=0, l=pages.length; i<l; i++) {
                // *** Store the promise returned by getSizeSettingsFromPage in a variable
                promise = getSizeSettingsFromPage(pages[i]);
                promise.then(function(values) {
                    var width = values[0],
                        height = values[1],
                        filename = values[2];
                    // *** When the promise is resolved, call calculateRatio
                    calculateRatio(width, height, filename);
                });
                // *** Add the promise returned by getSizeSettingsFromPage to the array
                promises.push(promise);
            }
            // *** Call checkWhenReady after all promises have been resolved
            Q.all(promises).then(checkWhenReady);
        }

        function getSizeSettingsFromPage(file) {
            // *** Create a Deferred
            var deferred = Q.defer();
            reader = new FileReader();
            reader.onload = function(evt) {
                var image = new Image();
                image.onload = function(evt) {
                    var width = this.width;
                    var height = this.height;
                    var filename = file.name;
                    // *** Resolve the Deferred
                    deferred.resolve([ width, height, filename ]);
                };
                image.src = evt.target.result;
            };
            reader.readAsDataURL(file);
            // *** Return a Promise
            return deferred.promise;
        }

编辑

defer创建一个延迟 ,它包含两个部分,一个promiseresolve功能。 该promise是通过返回getSizeSettingsFromPage 。 基本上返回许是给一个函数说的方式:“我会回来给你以后”。 一旦函数已经完成它的任务(在这种情况下,一旦image.onload事件已触发)的resolve函数是用来解决的承诺。 这表明,以任何等待这个任务已经完成了承诺。

这里有一个简单的例子:

function addAsync(a, b) {
    var deferred = Q.defer();
    // Wait 2 seconds and then add a + b
    setTimeout(function() {
        deferred.resolve(a + b);
    }, 2000);
    return deferred.promise;
}

addAsync(3, 4).then(function(result) {
    console.log(result);
});
// logs 7 after 2 seconds

addAsync功能增加了两个电话号码,但它加入他们之前等待2秒。 由于它是异步的,它会返回一个承诺( deferred.promse )和解析2秒钟的等待(后承诺deferred.resolve )。 在then的方法可以被称为一个承诺,并通过一个回调函数的承诺已经得到解决后执行。 回调函数是在承诺的分辨率值传递。

根据你的情况,我们有承诺的数组,我们需要等待所有的人在执行任务前,应完成的,所以我们用Q.all。 下面是一个例子:

function addAsync(a, b) {
    var deferred = Q.defer();
    // Wait 2 seconds and then add a + b
    setTimeout(function() {
        deferred.resolve(a + b);
    }, 2000);
    return deferred.promise;
}

Q.all([
    addAsync(1, 1),
    addAsync(2, 2),
    addAsync(3, 3)
]).spread(function(result1, result2, result3) {
    console.log(result1, result2, result3);
});
// logs "2 4 6" after approximately 2 seconds


Answer 2:

看起来你应该使用Q.all函数来创建相应的,当所有的getSizeSettings应许fufilled到主承诺。

https://github.com/kriskowal/q#combination

var ps = [];
for (var i=0, l=pages.length; i<l; i++) {
   ps[i] = getSizeSettingsFromPage(pages[i], calculateRatio);   
}

Q.all(ps).then(function(){ callWhenReady() })

最有希望图书馆应提供类似的方法做这种同步。 如果你遇到一个不你可以做的是钩每个人的承诺,即增加一个共用的反其调用时的回调是什么。 当您的计数器达到n你知道你已经解决了所有的诺言,所以你可以有增量器回调称之为“真正的”回调也是如此。

//If you did not have Q.all available
//Or had to code this without a promise library

var to_go = pages.length;
for (var i=0, l=pages.length; i<l; i++) {
   getSizeSettingsFromPage(pages[i], calculateRatio)
   .then(function(){
       to_go--;
       if(to_go == 0){
           callWhenReady()
       }
   });
}

注意,在这些情况下,到现在为止都允许异步调用运行并行。 如果你需要它们运行顺序,然后通常是唯一的办法就是重写for循环递归函数

var go = function(i){
    if(i>=pages.length){
        return call_next_step()
    }else{
        return do_ith_calculation(i)
        .then(function(){
            return go(i+1)
        })
    }
};
go(0);


文章来源: how to use q.js promises to work with multiple asynchronous operations