コルーチン

AWS SDK for Kotlin はデフォルトで非同期です。SDK for Kotlin は、コルーチンから呼び出されるすべてのオペレーションに suspend関数を使用します。

コルーチンの詳細なガイドについては、公式の Kotlin ドキュメントを参照してください。

同時リクエストの実行

非同期コルーチンビルダーを使用して、結果を重視する同時リクエストを起動できます。 は、後で結果を提供する promise を表す、軽量でノンブロッキングの未来を表す Deferred asyncを返します。

結果に関心がない場合 (オペレーションが完了した場合のみ）、起動コルーチンビルダーを使用できます。 launchは概念的に に似ていますasync。違いは、起動がジョブを返し、結果の値は持たず、 は asyncを返すことですDeferred。

以下は、headObject オペレーションを使用して Amazon S3 への同時リクエストを行い、2 つのキーのコンテンツサイズを取得する例です。

import kotlinx.coroutines.async
import kotlinx.coroutines.runBlocking
import kotlin.system.measureTimeMillis
import aws.sdk.kotlin.services.s3.S3Client


fun main(): Unit = runBlocking {

    val s3 = S3Client { region = "us-east-2" }
    
    val myBucket = "<your-bucket-name-here>"
    val key1 = "<your-object-key-here>"
    val key2 = "<your-second-object-key-here>"

    val resp1 = async {
        s3.headObject{
            bucket = myBucket
            key = key1
        }
    }

    val resp2 = async {
        s3.headObject{
            bucket = myBucket
            key = key2
        }
    }


    val elapsed = measureTimeMillis {
        val totalContentSize = resp1.await().contentLength + resp2.await().contentLength
        println("content length of $key1 + $key2 = $totalContentSize")
    }

    println("requests completed in $elapsed ms")

}

ブロックリクエストの作成

コルーチンを使用せず、別のスレッドモデルを実装する既存のコードからサービス呼び出しを行うには、runBlocking コルーチンビルダーを使用できます。別のスレッドモデルの例としては、Java の従来のエグゼキュター/未来アプローチの使用があります。Java と Kotlin のコードまたはライブラリをブレンドする場合は、このアプローチを使用する必要がある場合があります。

名前が示すように、このrunBlockingビルダーは新しいコルーチンを起動し、完了するまで現在のスレッドをブロックします。