追記2016/02/26:「並列処理」と「非同期処理」を混同して回答していました。下記回答は、obj
の各要素を受け取った非同期的な処理に対して、「全ての処理完了を待つ」ものと「最初に完了した処理を待つ」例として残しておきます。
Promise.all
(並列各処理を実行して全ての処理完了を待つ)またはPromise.race
(並列各処理を実行して最初に終わった処理だけ待つ)を使います。
index.js
var obj = [
{a:"abc",b:123,c:true},
{a:"efg",b:456,c:true},
{a:"hij",b:789,c:false}
];
var promises = obj.map(function(data) {
return new Promise(function(resolve, reject) {
// ここに処理
var delay = Math.floor(Math.random() * 5000); /* ランダムに0〜5秒 */
setTimeout(function() {
console.log('processing:', delay + '[msec]', data);
// 完了(成功)時には resolve() を、失敗時には reject() を呼ぶ
resolve(data);
}, delay);
});
});
Promise.all(promises).then(function(results) {
console.log('results:', results);
});
実行結果の一例は以下のようになります。ランダムで待ち時間を設定しているので実行のたびに結果が変わります。
% node -v
v5.5.0
% time node index.js
processing: 1099[msec] { a: 'efg', b: 456, c: true }
processing: 1975[msec] { a: 'abc', b: 123, c: true }
processing: 2648[msec] { a: 'hij', b: 789, c: false }
results: [ { a: 'abc', b: 123, c: true },
{ a: 'efg', b: 456, c: true },
{ a: 'hij', b: 789, c: false } ]
node index.js 0.10s user 0.02s system 4% cpu 2.735 total
time
は最終行のように実行時間を出力するコマンドで、node index.js
の実行時間(total)が最も時間がかかった処理と同程度になっていることから並列処理されていることが分かると思います。
Promise.race
を使うと以下のように、最初に完了した時点で後続の処理(then
以下)が実行されます。
% node -v
v5.5.0
% time node index.js
processing: 663[msec] { a: 'hij', b: 789, c: false }
results: { a: 'hij', b: 789, c: false }
processing: 727[msec] { a: 'abc', b: 123, c: true }
processing: 2264[msec] { a: 'efg', b: 456, c: true }
node index.js 0.08s user 0.02s system 4% cpu 2.333 total
この場合のindex.js
は、最後の部分を以下のようにしています。
Promise.race(promises).then(function(results) {
console.log('results:', results);
});
参考:Promise - JavaScript | MDN