So sch\u00f6ne an Future-Objekten ist die Abarbeitung im Hintergrund und die M\u00f6glichkeit, sp\u00e4ter abzufragen, ob das Ergebnis schon da ist. Allerdings fehlt der Future-Schnittstelle eine Methode, automatisch nach der Fertigstellung einen Folgeauftrag abzuarbeiten. Daf\u00fcr bietet die Java-Bibliothek eine spezielle Unterklasse CompletableFuture. Die Klasse implementiert die Schnittstelle CompletionStage, die vermutlich die gr\u00f6\u00dfte Anzahl Operationen in der gesamten Java SE hat. Der Typname dr\u00fcckt aus, das es um die Fertigstellung (engl. completion) von Abschnitten (engl. stage) geht.<\/p>\n
Ein Beispiel f\u00fcr einen trinkfesten mutigen Piraten:<\/p>\n
package com.tutego.insel.concurrent;\n\n\n\n\nimport java.time.LocalTime;\n\nimport java.util.concurrent.CompletableFuture;\n\nimport java.util.concurrent.TimeUnit;\n\nimport java.util.logging.Logger;\n\n\n\n\nclass Pirate {\n\n\n\n\n public static void main( String[] arg ) throws Throwable {\n\n\n\n\n String result = CompletableFuture.supplyAsync( Pirate::newName )\n\n .thenApply( Pirate::swears )\n\n .thenCombine( drinkRum(), Pirate::combinePiratAndDrinks )\n\n .thenCombine( drinkRum(), Pirate::combinePiratAndDrinks )\n\n .get();\n\n System.out.println( result ); \/\/ Pirat Guybrush flucht und trinkt dann 10 Flaschen Rum und trinkt dann 11 Flaschen Rum\n\n }\n\n\n\n\n static String newName() {\n\n Logger.getGlobal().info( \"\" + Thread.currentThread() );\n\n return \"Pirat Guybrush\";\n\n }\n\n\n\n\n static String swears( String pirate ) {\n\n Logger.getGlobal().info( \"\" + Thread.currentThread() );\n\n return pirate + \" flucht\";\n\n }\n\n\n\n\n static CompletableFuture<Integer> drinkRum() {\n\n Logger.getGlobal().info( \"\" + Thread.currentThread() );\n\n try { TimeUnit.SECONDS.sleep( 1 ); } catch ( Exception e ) { }\n\n return CompletableFuture.supplyAsync( () -> LocalTime.now().getSecond() );\n\n }\n\n\n\n\n static String combinePiratAndDrinks( String pirat, int bottlesOfRum ) {\n\n Logger.getGlobal().info( \"\" + Thread.currentThread() );\n\n return pirat + \" und trinkt dann \" + bottlesOfRum + \" Flaschen Rum\";\n\n }\n\n}<\/pre>\nDie Ausgabe ist:<\/p>\n
Juni 15, 2017 10:41:56 NACHM. com.tutego.insel.thread.concurrent.Pirate drinkRum\n\nINFORMATION: Thread[main,5,main]\n\nJuni 15, 2017 10:41:56 NACHM. com.tutego.insel.thread.concurrent.Pirate newName\n\nINFORMATION: Thread[ForkJoinPool.commonPool-worker-1,5,main]\n\nJuni 15, 2017 10:41:56 NACHM. com.tutego.insel.thread.concurrent.Pirate swears\n\nINFORMATION: Thread[ForkJoinPool.commonPool-worker-1,5,main]\n\nJuni 15, 2017 10:41:57 NACHM. com.tutego.insel.thread.concurrent.Pirate combinePiratAndDrinks\n\nINFORMATION: Thread[main,5,main]\n\nJuni 15, 2017 10:41:57 NACHM. com.tutego.insel.thread.concurrent.Pirate drinkRum\n\nINFORMATION: Thread[main,5,main]\n\nJuni 15, 2017 10:41:58 NACHM. com.tutego.insel.thread.concurrent.Pirate combinePiratAndDrinks\n\nINFORMATION: Thread[main,5,main]\n\nPirat Guybrush flucht und trinkt dann 57 Flaschen Rum und trinkt dann 58 Flaschen Rum<\/pre>\nZum Programm: Zun\u00e4chst muss die Kette von Abschnitten aufgebaut werden. Das kann entweder mit dem Standardkonstruktor geschehen, oder mit statischen Methoden. In unserem Fall nutzen wir supplyAsync(Supplier<U> supplier). Die Methode nimmt sich einen freien Thread aus dem ForkJoinPool.commonPool() und l\u00e4sst den Thread den supplier abarbeiten. Das Ergebnis ist \u00fcber die R\u00fcckgabe, einem CompletableFuture, abrufbar. Als n\u00e4chsten wenden wir thenApply(Function<? super T,? extends U> fn) an, die vergleichbar ist mit einer map(\u2026)-Operation eines Streams. Interessant wird es bei thenCombine(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn); sie verbindet das Ergebnis der eigenen CompletionStage \u00fcber eine Funktion mit einer anderen CompletionStage, die wir in unserem Fall auch wieder mit supplyAsync(\u2026) aufbauen. So kombinieren wir zwei unabh\u00e4ngige CompletionStage miteinander und synchronisieren das Ergebnis. Wir k\u00f6nnen das gut an der Ausgabe auslesen, dass drinkRum ganz am Anfang schon ausgef\u00fchrt wird, und zwar vom Thread[main,5,main], nicht vom ForkJoinPool, weil es unabh\u00e4ngig von den anderen l\u00e4uft.<\/p>\n","protected":false},"excerpt":{"rendered":"
So sch\u00f6ne an Future-Objekten ist die Abarbeitung im Hintergrund und die M\u00f6glichkeit, sp\u00e4ter abzufragen, ob das Ergebnis schon da ist. Allerdings fehlt der Future-Schnittstelle eine Methode, automatisch nach der Fertigstellung einen Folgeauftrag abzuarbeiten. Daf\u00fcr bietet die Java-Bibliothek eine spezielle Unterklasse CompletableFuture. Die Klasse implementiert die Schnittstelle CompletionStage, die vermutlich die gr\u00f6\u00dfte Anzahl Operationen in der […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_jetpack_memberships_contains_paid_content":false,"footnotes":"","_links_to":"","_links_to_target":""},"categories":[1,11,85],"tags":[],"class_list":["post-3868","post","type-post","status-publish","format-standard","hentry","category-allgemein","category-insel","category-java-9"],"jetpack_featured_media_url":"","jetpack_sharing_enabled":true,"_links":{"self":[{"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/posts\/3868","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/comments?post=3868"}],"version-history":[{"count":4,"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/posts\/3868\/revisions"}],"predecessor-version":[{"id":4498,"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/posts\/3868\/revisions\/4498"}],"wp:attachment":[{"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/media?parent=3868"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/categories?post=3868"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/tags?post=3868"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}