[Node.js] 非同期処理 - async/await編

async/await

async/await構文

function parseJSONAsync(json) {
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            try {
                resolve(JSON.parse(json))
            } catch (err) {
                reject(err)
            }
        }, 1000)
    })
}
async function asyncFunc(json) {
    try{
        const result = await parseJSONAsync(json);
        console.log('パース結果', result);
    }catch (err) {
        console.log('エラーをキャッチ', err);
    }
}
asyncFunc('{"foo": 1}')
asyncFunc('不正なJSON')
>>>
ース結果 { foo: 1 }
エラーをキャッチ SyntaxError: Unexpected token 不 in JSON at position 0
    at JSON.parse (<anonymous>)
    ...(省略)

asyncキーワードの付いた関数は必ずPromiseインスタンスを返します。それは関数内で非同期処理が実行されない場合でも、同様です。

async function asyncReturnFoo() { return 'foo' }
const result = asyncReturnFoo()
console.log(result)
>>>
Promise { 'foo' }

また、async関数内でエラーが投げられると、async関数はrejectedなPromiseインスタンスを返します。

async function asyncTrhow() { throw new Error('エラー') }
const result = asyncTrhow()
console.log(result)
>>>
Promise {
  <rejected> Error: エラー
  ...(省略)
}
(node:23161) UnhandledPromiseRejectionWarning: Error: エラー
...(省略)

awaitはasync関数ないの処理を一時停止するものの、非同期I/Oのようにスレッドの処理をブロックするわけではありません。asunc関数が一時停止している間も、async関数の外の処理は動作を続けます。

async function pauseAndResume(pausePeriod) {
    console.log('pauseAndResume開始')
    await new Promise(resolve => setTimeout(resolve, pausePeriod))
    console.log('pauseAndResume終了')
}
pauseAndResume(1000)
console.log('async関数外の処理はawaitの影響を受けない')
>>>
pauseAndResume開始
async関数外の処理はawaitの影響を受けない
pauseAndResume終了

並行処理

async/await構文には並行実行のための機能はないため、Promise.all()などのスタティックメソッドと組み合わせる必要がある。

async function doSomethingAsyncConcurrently() {
    const result = await Promise.all([
        asyncFunc1(),
        asyncFunc2(),
        asyncFunc3()
    ]);
}

for await ...of 構文

for await ... of はasyncイテラブルに対して反復処理を行います。
asyncジェネレータ関数を使って簡単な例を書いてみます。

sync function* asyncGenerator() {
    let i = 0;
    while(i <= 3) {
        await new Promise(resolve => setTimeout(resolve, 1000));
        yield i++
    }
}
for await (const value of asyncGenerator()) {
    console.log(value);
}
>>>
0
1
2
3