La classe
CompletableFuture
<strong>public class CompletableFuture<T> extends Object implements Future<T>, CompletionStage<T></strong>
import java.util.function.Supplier; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; public class CompletableFutureTest { public static void main(String args[]) throws ExecutionException, InterruptedException { Calculator calc = new Calculator(4, 7); <strong>CompletableFuture<Integer></strong> future = CompletableFuture.<strong>supplyAsync</strong>(calc); future.<strong>thenAccept</strong>(result -> { System.out.println(result); }); System.out.println("CompletableFutureTest End.... "); Thread.sleep(10000); } } <strong>// Calculator class</strong> class Calculator implements <strong>Supplier<Integer></strong> { private int x, y; public Calculator(int x, int y) { this.x = x; this.y = y; } <strong>@Override</strong> public Integer get() { try { Thread.sleep(3000); } catch(InterruptedException e) { e.printStackTrace(); } return x + y; } }
<strong>CompletableFutureTest End.... 11</strong>
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!