在 for 循环中连续运行两个或多个异步操作的最佳方法

Question

我有以下循环遍历对象列表的方法，并且您需要为每个节点执行一个承诺。在 for 循环中连续执行两个或多个异步操作的最佳方法是什么？

 async cargarEstadosPools() {
    let that = this;
    let nodo: Nodo;      
 
    for (var i = 0; i < that.aplicacionEntorno.entorno.nodos.length; i++) {
        this.appService.loading = true;
        nodo = that.aplicacionEntorno.entorno.nodos[i];    
        await that.obtenerDatos.Metodo(this.ruta + 'api/nodo' + '/' + aplicacionId)
        .then((res: any) => {             
            if (res != 'Started' && res != 'Stopped') {
                nodo.errorPool = res;
                nodo.estadoPool = 'Error';
            }
            else {
                nodo.errorPool = '';
                nodo.estadoPool = res;
            }
            nodo.ejecutandoAccionNodo = false;
            that.appService.loading = false;
        })
    }     
}

Answer 1

要在 for 循环中触发彼此并行的异步函数的执行，您应该这样做：

await Promise.all(that.aplicacionEntorno.entorno.nodos.map(nodo => {  
        await that.obtenerDatos.Metodo(this.ruta + 'api/nodo' + '/' + aplicacionId)
        .then((res: any) => {             
            if (res != 'Started' && res != 'Stopped') {
                nodo.errorPool = res;
                nodo.estadoPool = 'Error';
            }
            else {
                nodo.errorPool = '';
                nodo.estadoPool = res;
            }
            nodo.ejecutandoAccionNodo = false;
            that.appService.loading = false;
        })
    }

来自 .

Answer 2

由于您正在使用 angular，您可以考虑使用 observables。将上面的转换为可观察的会变成下面这样的东西

import { from, forkJoin } from 'rxjs';
import { tap } from 'rxjs/operators';

...

cargarEstadosPools() {
  this.appService.loading = true;
  return forkJoin(
    aplicacionEntorno.entorno.nodos.map(nodo => 
      from(obtenerDatos.Metodo(this.ruta + 'api/nodo' + '/' + aplicacionId))
    )
  ).pipe(
    tap(() =>  this.appService.loading = false)
  )
}

我们正在使用代码

创建一个可观察数组

    aplicacionEntorno.entorno.nodos.map(nodo => 
      from(obtenerDatos.Metodo(this.ruta + 'api/nodo' + '/' + aplicacionId))
    )

然后我们用 forkJoin([observable1, obsevable2, ...])

加入这个数组

我们使用 pipe 和 tap 运算符在所有 observable 完成后将加载设置为 false

在 for 循环中连续运行两个或多个异步操作的最佳方法

best way to run two or more asynchronous operations in a row inside a for loop

angular-promise

angular

在 for 循环中连续 运行 两个或多个异步操作的最佳方法

best way to run two or more asynchronous operations in a row inside a for loop

angular-promise

angular

在 for 循环中连续运行两个或多个异步操作的最佳方法