Kotlin/anko mehrere asynchrone Aufgaben

Question

Ich bin auf der Suche nach einer einfachen Möglichkeit, mehrere Aufgaben parallel zu starten und warten auf alle von ihnen abzuschließen.

Betrachten Sie diese C# Beispiel:

private static void Main(string[] args) 
{ 
    var urlList = new[] {"http://www.microsoft.com/", "http://www.google.com/", "http://www.apple.com/" }; 
    var result = GetHtml(urlList); 
} 

private static List<string> GetHtml(string[] urlList) 
{ 
    var tasks = new List<Task>(); 
    var output = new List<string>(); 

    foreach (var url in urlList) 
    { 
     var task = new Task(() => 
     { 
      var html = new WebClient().DownloadString(url); 
      output.Add(html); 
     }); 

     tasks.Add(task); 

     //starts task in a separate thread (doesn't block anything) 
     task.Start(); 
    } 

    //waits for all tasks (running in parallel) to complete before exiting method 
    Task.WaitAll(tasks.ToArray()); 

    return output; 
} 

getHTML Methode mehrere Web-Seiten parallel herunterlädt und gibt eine Liste von HTML-Strings.

Wie kann ich dies mit Kotlin/Anko erreichen?

private fun GetHtml(urlList: Array<String>): ArrayList<String> { 

    val tasks = ArrayList<Future<Unit>>() 
    val output = ArrayList<String>() 

    for (url in urlList) { 
     val task = async() { 
      //some java-code that downloads html from <url>, doesn't matter for now 
      output.add("html for $url") 
     } 
     tasks.add(task) 
    } 

    //this is NOT parallel execution 
    for (task in tasks) { 
     task.get()   
    } 

    //tasks.getall() ?? 

    return output 
} 

Answer 1

Basierend auf Eingaben von Michael und pdegand59, hier ist eine Arbeitslösung:

private fun GetHtml(urlList: Array<String>): ArrayList<String> { 

    val pool = Executors.newFixedThreadPool(urlList.count()) 
    val countDownLatch = CountDownLatch(urlList.count()) 

    val output = ArrayList<String>() 

    for (url in urlList) { 

     async(pool, { 
      //some java-code that downloads html for <url> 
      output.add("html for $url") 
      countDownLatch.countDown() 
     })  
    } 

    countDownLatch.await() 

    return output 
} 

Answer 2

Ich würde vorschlagen, CountDownLatch in einem separaten Thread verwenden, um den Haupt-Thread während alles parallelen Downloads nicht blockiert :

private fun downloadAllHtml(urlList: Array<String>) { 
    val output = ArrayList<String>() 
    val countDownLatch = CountDownLatch(urlList.length) 

    async(Executors.newSingleThreadExecutor() { 
    countDownLatch.await() 
    uiThread { 
     onAllHtmlDownloaded(output) 
    } 
    } 

    urlList.forEach { url: String -> 
    async() { 
     // download stuff 
     output.add("stuff downloaded") 
     countDownLatch.countDown() 
    } 
    } 
    // this method ends instantly, not blocking the main thread 
} 

private fun onAllHtmlDownloaded(output: ArrayList<String>) { 
    // all your html, on the main thread 
} 

Sie müssen möglicherweise etwas Versuch/Fang hinzufügen. Die IDE wird dir helfen;)