Javascript.同步运行多个承诺

Javascript.Run Multi promises Synchronously

本文关键字:承诺 运行 同步 Javascript      更新时间:2023-09-26

我想申请一个网站40次。

我希望这是同步的,像10个请求4次。

这是我的代码,用于1次请求-40次:

'use strict';
var request = require('request');
var co = require('co');

function callUrl(url) {
    return new Promise((resolve, reject) => {
        request.get(url, (e, r, b) => {
            if (e) reject(e)
            else
                resolve(`Response from ${url}`);
        });
    })
}

co(function*() {
        for (var i = 1; i < 41; i++) {
            let rs = yield callUrl('https://www.google.com/?q=' + i);
            // let rs = yield makeUrls(10,i);
            console.log(rs);
        }
    });

我可以做出一系列承诺,但我不知道如何将q的值更改为不同的值。

你不想同步运行它们-你想同步它们-它们是不同的。

您可以将一系列promise与Promise#all一起使用。当您创建一个promise时,操作已经在执行了——只有yield会同步。

你可以像这样一次提出10个请求:

co(function*() {
    for (var i = 1; i < 41;) {
        var promises = [];
        for(var lim = i + 10; i < Math.max(lim, 41); i++) {
           promises.push(callUrl('https://www.google.com/?q=' + i));
        }
        let rs = yield Promise.all(promises); // wait for everything
        console.log(rs); // an array of 10 results
});

请注意,除此之外,您的代码仍然不是很高效——如果10个请求中有9个请求非常快,而一个请求需要一分钟的时间,会发生什么?您将只有一个传出请求。您可以使用像bluebird这样的库,该库具有更高效的带有并发参数的Promise.map方法。

这可能在不使用生成器的情况下工作

const urls = [/*array of urls*/];
const initialPromise = request[urls[0]];
let promise = initialPromise;
for(let i= 1; i<40;i++){
  let thenFunction = response => {
    //do something with the response
    return request(urls[i])
  }
  promise = promise.then(thenFunction)
}

这背后的想法是建立承诺链,这样下一个承诺将放弃上一个承诺来完成