Tengo un ciclo de 100 promesas. Quiero procesar 10 de esos simultáneamente, luego imprimir una declaración y continuar con los siguientes 10 en paralelo. Sin embargo, no espera que cada 10 promesas terminen su ejecución.

const promises = [];
for (let i = 1; i <= 100; i ++) {

   const blockPromise = this.web3.eth.getBlock(i).then((block: any) => {
        winston.info("Processing block " + i);
   }).catch((err: Error) => {
        winston.error(err);
   });

   promises.push(blockPromise);

   if (i % 10 === 0) {
       Promise.all(promises).then(() => {
            winston.info("+++ Processed " + 10 + " blocks");
       }).catch((err: Error) => {
            winston.error(err);
       });
   }

Mi expectativa es algo como:

Processing block 1
Processing block 3
Processing block 7
Processing block 2
Processing block 4
Processing block 5
Processing block 6
Processing block 9
Processing block 10
Processing block 8
+++ Processed 10 blocks
Processing block 12
...

Sin embargo, está caóticamente mezclado. ¿Qué estoy haciendo mal? Cualquier ayuda apreciada.

3
phoebus 30 oct. 2017 a las 11:49

3 respuestas

La mejor respuesta

Ya que está tratando de procesar 10 promesas cada vez, ¿podría await después de cada lote de 10 o eso sería contrario al propósito?

var promises = []; // You are mutating it so better not be a const
var blockPromise = null;
for (let i = 1; i <= 100; i ++) {

 blockPromise = this.web3.eth.getBlock(i).then((block: any) => {
      winston.info("Processing block " + i);
 }).catch((err: Error) => {
      winston.error(err);
 });

 promises.push(blockPromise);

 if (i % 10 === 0) {
     await Promise.all(promises);
     promises = [] // clear the processed promises as well
     winston.info("+++ Processed " + 10 + " blocks");
 }
}
1
Nandu Kalidindi 30 oct. 2017 a las 09:00

Otra solución es usar array reduce para encadenar sus promesas:

var groups = Array.from(new Array(10),(val,index) => 10*index);	// => [0, 10, 20, 30, 40, 50, 60, 70, 80, 90]
groups.reduce((m, o) => {
    return m.then(() => {		
        var group = Array.from(new Array(10), (val, index) => o + index + 1);  // [1, 2, 3, 4, 5, 6, 7, 8, 9, 10], [11, 12, 13, 14, 15, 16, 17, 18, 19, 20], ...
        var promises = group.map(i => this.web3.eth.getBlock(i).then(() => winston.info("Processing block " + i)) );
        return Promise.all(promises).then(() => winston.info("+++ Processed " + 10 + " blocks") );
    });
}, Promise.resolve(true));   

Simplemente te da el resultado esperado:

enter image description here

2
Faly 30 oct. 2017 a las 09:40

Las promesas dentro de los bucles arruinan todo. O usa async y espera, o necesita reducir todo a una cadena de promesa:

let promise = Promise.resolve(), promises = [];
for( let i = 0; i <= 100; i++){
  promises.push(this.web3.eth.getBlock(i).then((block: any) => {
         winston.info("Processing block " + i);
     }).catch((err: Error) => {
         winston.error(err);
  }));

  if (i % 10 === 0){
   promise = Promise.all(promises.concat(promise))
      .then(_=>winston.info("+++ Processed " + 10 + " blocks");  
   promises = [];           
  }
}
1
Jonas Wilms 30 oct. 2017 a las 09:27