как использовать await или async в jvm kotlin? - PullRequest
0 голосов
/ 06 октября 2018

Я пытаюсь написать пример в функциях kotlin await / async, которые должны работать так же, как пример ac # await.Это работает без ошибок, но я не уверен, правильно ли я понимаю их обоих, и, возможно, я создаю слишком много асинхронных сопрограмм.Кто-нибудь может дать мне несколько советов по этому поводу?спасибо.

https://docs.microsoft.com/en-us/dotnet/csharp/programming-guide/concepts/async/how-to-make-multiple-web-requests-in-parallel-by-using-async-and-await

package diki.test

import kotlinx.coroutines.experimental.async
import kotlinx.coroutines.experimental.runBlocking
import org.apache.commons.lang3.RandomUtils

fun main(args: Array<String>) = runBlocking {
    val start = System.currentTimeMillis()
    startButton_Click().await();
    println("time=" + (System.currentTimeMillis() - start))
}

fun startButton_Click() = async {
    CreateMultipleTasksAsync().await()
}

fun CreateMultipleTasksAsync() = async {
    val d1 = ProcessURLAsync("http://a")
    val d2 = ProcessURLAsync("http://a1")
    val d3 = ProcessURLAsync("http://a111")
    val d1r = d1.await()
    val d2r = d2.await()
    val d3r = d3.await()
}

fun ProcessURLAsync(url: String) = async {
    Thread.sleep(RandomUtils.nextLong(500, 1000))//mock network job
    url.length
}

1 Ответ

0 голосов
/ 14 октября 2018

async/await для CreateMultipleTasksAsync и startButton_Click бесполезно.Просто сделайте их suspend функциями.

И +1 для delay вместо Thread.sleep

...