JavaScriptでasync/awaitを使って複数の非同期処理を実行する

2024-04-11

Node.jsネイティブのPromise.allは並列処理か逐次処理か？

解説:

Promise.allは、複数の非同期処理をまとめて実行し、すべての処理が完了した時に結果を返すPromiseオブジェクトを生成します。

Node.jsのイベントループは、非同期処理を効率的に処理するために設計されています。イベントループは、処理待ちのキューと、実行中の処理のスタックを持ちます。

Promise.allは、渡されたすべてのPromiseオブジェクトをキューに追加します。イベントループは、キューからPromiseオブジェクトを取り出し、実行可能なものがあれば実行します。

複数のPromiseオブジェクトが実行可能な場合、イベントループはそれらを並列で実行します。これは、Node.jsの非同期処理モデルによって可能になります。

例:

const promise1 = new Promise((resolve) => {
  setTimeout(() => {
    resolve('Promise 1');
  }, 1000);
});

const promise2 = new Promise((resolve) => {
  setTimeout(() => {
    resolve('Promise 2');
  }, 2000);
});

Promise.all([promise1, promise2]).then((results) => {
  console.log(results); // ['Promise 1', 'Promise 2']
});

この例では、promise1とpromise2はそれぞれ1秒と2秒後に解決されます。Promise.allは、これらの2つのPromiseオブジェクトを並列で実行し、両方のPromiseオブジェクトが解決されると、結果の配列をthenハンドラに渡します。

注意点:

Promise.allは、渡されたすべてのPromiseオブジェクトが解決されるまで待機します。そのため、一部のPromiseオブジェクトが解決に時間がかかる場合、全体の処理時間が長くなります。
Promise.allは、処理の順序を保証しません。並列処理によって、処理の順序が渡された順序と異なる場合があります。

const promise1 = new Promise((resolve) => {
  setTimeout(() => {
    resolve('Promise 1');
  }, 1000);
});

const promise2 = new Promise((resolve) => {
  setTimeout(() => {
    resolve('Promise 2');
  }, 2000);
});

Promise.all([promise1, promise2]).then((results) => {
  console.log(results); // ['Promise 1', 'Promise 2']
});

例2: 処理の順序を保証しない

const promise1 = new Promise((resolve) => {
  setTimeout(() => {
    resolve('Promise 1');
  }, 2000);
});

const promise2 = new Promise((resolve) => {
  setTimeout(() => {
    resolve('Promise 2');
  }, 1000);
});

Promise.all([promise1, promise2]).then((results) => {
  console.log(results); // ['Promise 2', 'Promise 1']
});

例3: エラー処理

const promise1 = new Promise((resolve, reject) => {
  setTimeout(() => {
    reject(new Error('Error'));
  }, 1000);
});

const promise2 = new Promise((resolve) => {
  setTimeout(() => {
    resolve('Promise 2');
  }, 2000);
});

Promise.all([promise1, promise2]).catch((error) => {
  console.log(error); // Error: Error
});

これらのサンプルコードは、Promise.allの使用方法を理解するのに役立ちます。

Promise.all 以外の方法

async/await は、非同期処理をより直感的に記述できる構文です。

async function main() {
  const result1 = await promise1;
  const result2 = await promise2;

  console.log(result1, result2); // 'Promise 1', 'Promise 2'
}

main();

for ループを使用して、複数の非同期処理を順番に実行できます。

for (const promise of [promise1, promise2]) {
  const result = await promise;
  console.log(result); // 'Promise 1', 'Promise 2'
}

ライブラリ

async や bluebird などのライブラリは、複数の非同期処理を処理するための便利な機能を提供します。

const async = require('async');

async.parallel([
  function(callback) {
    setTimeout(() => {
      callback(null, 'Promise 1');
    }, 1000);
  },
  function(callback) {
    setTimeout(() => {
      callback(null, 'Promise 2');
    }, 2000);
  }
], (error, results) => {
  console.log(results); // ['Promise 1', 'Promise 2']
});