等待多个并行操作

Question

等待多个并行操作

如何更改以下代码，以便触发两个异步操作并使其有机会并发运行？

const value1 = await getValue1Async();

const value2 = await getValue2Async();

// use both values

我需要这样做吗？

const p1 = getValue1Async();

const p2 = getValue2Async();

const value1 = await p1;

const value2 = await p2;

// use both values

Answer 1

我认为这应该有效： const [value1, value2] = await Promise.all([getValue1Async(),getValue2Async()]);下面是一个更详细的示例，以便于理解：const promise1 = async() => {   return 3;}const promise2 = async() => {   return 42;}const promise3 = async() => {   return 500;   // emulate an error   // throw "something went wrong...";}const f1 = async() => {   try {     // returns an array of values     const results = await Promise.all([promise1(), promise2(), promise3()]);     console.log(results);     console.log(results[0]);     console.log(results[1]);     console.log(results[2]);     // assigns values to individual variables through 'array destructuring'     const [value1, value2, value3] = await Promise.all([promise1(), promise2(), promise3()]);     console.log(value1);     console.log(value2);     console.log(value3);   } catch (err) {     console.log("there was an error: " + err);   }}f1();

Answer 2

使用.catch()和Promise.all()确保正确处理拒绝，并且可以安全地使用Promises.all()而不面临未处理的拒绝。(编辑：每次讨论澄清：不是错误unhandled rejection但是简单地说，拒绝是不被代码处理的。Promise.all()会抛出第一个承诺，拒绝和意志视而不见其他的)。在下面的示例中，一个[错误，结果]，.]数组返回以便于处理结果和/或错误。let myTimeout = (ms, is_ok) =>   new Promise((resolve, reject) =>      setTimeout(_=> is_ok ?                     resolve(`ok in ${ms}`) :                    reject(`error in ${ms}`),                ms));let handleRejection = promise => promise  .then((...r) => [null, ...r])   .catch(e => [e]); (async _=> {   let res = await Promise.all([     myTimeout(100, true),     myTimeout(200, false),     myTimeout(300, true),     myTimeout(400, false)   ].map(handleRejection));   console.log(res);})();但是，您可以从CATCH()中抛出，以停止等待所有的结果(并丢弃其余的结果)-您可以每次尝试/捕获块只执行一次，因此需要维护和检查旗标SADS_SOWN，以确保不会发生未处理的错误。let myTimeout = (ms, is_ok) =>   new Promise((resolve, reject) =>     setTimeout(_=> is_ok ?                    resolve(`ok in ${ms}`) :                    reject(`error in ${ms}`),                ms));let has_thrown = false;let handleRejection = promise => promise  .then((...r) => [null, ...r])   .catch(e => {     if (has_thrown) {       console.log('not throwing', e);     } else {       has_thrown = 1;       throw e;     }   });(async _=> {   try {     let res = await Promise.all([       myTimeout(100, true),       myTimeout(200, false),       myTimeout(300, true),       myTimeout(400, false)     ].map(handleRejection));     console.log(res);   } catch(e) {     console.log(e);   }   console.log('we are done');})();