如何在多个异步操作中并行执行某些操作？

在JavaScript中，要在多个异步操作中并行执行某些操作，有多种实现方式，以下是一些常见的方法：

使用Promise.all

Promise.all方法可以接收一个Promise数组，当所有Promise都成功完成时，它返回一个包含所有Promise结果的数组。如果其中任何一个Promise被拒绝，Promise.all将立即返回一个被拒绝的Promise，并传递第一个被拒绝的Promise的理由。

const asyncOperation1 = () => new Promise(resolve => setTimeout(() => resolve('结果1'), 1000));
const asyncOperation2 = () => new Promise(resolve => setTimeout(() => resolve('结果2'), 1500));
const asyncOperation3 = () => new Promise(resolve => setTimeout(() => resolve('结果3'), 2000));

async function parallelOperations() {
   
    try {
   
        // 并行执行三个异步操作
        const results = await Promise.all([asyncOperation1(), asyncOperation2(), asyncOperation3()]);
        console.log('所有异步操作结果：', results);
    } catch (error) {
   
        console.error('出现错误：', error);
    }
}

parallelOperations();

使用Promise.allSettled

Promise.allSettled方法也接受一个Promise数组，它会等到所有Promise都完成（无论是成功还是失败），然后返回一个包含每个Promise结果的对象数组，每个对象都有status属性（fulfilled或rejected）和value或reason属性，分别表示成功的值或失败的原因。

const asyncOperation1 = () => new Promise(resolve => setTimeout(() => resolve('结果1'), 1000));
const asyncOperation2 = () => new Promise((_, reject) => setTimeout(() => reject('操作2失败'), 1500));
const asyncOperation3 = () => new Promise(resolve => setTimeout(() => resolve('结果3'), 2000));

async function parallelOperations() {
   
    const results = await Promise.allSettled([asyncOperation1(), asyncOperation2(), asyncOperation3()]);
    results.forEach(result => {
   
        if (result.status === 'fulfilled') {
   
            console.log('成功：', result.value);
        } else {
   
            console.error('失败：', result.reason);
        }
    });
}

parallelOperations();

使用async函数和await在循环中并行

可以在async函数内部使用for...of循环或map方法结合await来并行执行异步操作。在循环中，每个异步操作都会启动，然后await会等待所有异步操作都完成。

const asyncOperations = [
    () => new Promise(resolve => setTimeout(() => resolve('结果1'), 1000)),
    () => new Promise(resolve => setTimeout(() => resolve('结果2'), 1500)),
    () => new Promise(resolve => setTimeout(() => resolve('结果3'), 2000))
];

async function parallelOperations() {
   
    try {
   
        const results = await Promise.all(asyncOperations.map(operation => operation()));
        console.log('所有异步操作结果：', results);
    } catch (error) {
   
        console.error('出现错误：', error);
    }
}

parallelOperations();

使用RxJS库

RxJS库提供了forkJoin操作符，它类似于Promise.all，可以并行执行多个Observable，并在所有Observable都发出最后一个值后返回一个包含所有结果的数组。

const {
    forkJoin, of } = require('rxjs');
const {
    delay } = require('rxjs/operators');

const asyncOperation1 = of('结果1').pipe(delay(1000));
const asyncOperation2 = of('结果2').pipe(delay(1500));
const asyncOperation3 = of('结果3').pipe(delay(2000));

forkJoin([asyncOperation1, asyncOperation2, asyncOperation3])
   .subscribe({
   
        next: results => console.log('所有异步操作结果：', results),
        error: error => console.error('出现错误：', error)
    });