Java CompletableFuture的complete（7）

Java CompletableFuture的complete（7）

先看代码：

 CompletableFuture<String> future = CompletableFuture.supplyAsync(new Supplier<String>() { @Override public String get() { try { TimeUnit.SECONDS.sleep(2); } catch (Exception e) { e.printStackTrace(); } return "blog.csdn.net/zhangphil"; } }); System.out.println(System.currentTimeMillis() + ":time 1"); future.whenCompleteAsync(new BiConsumer<String, Throwable>() { @Override public void accept(String s, Throwable throwable) { System.out.println(System.currentTimeMillis() + ":" + s); } }); System.out.println(System.currentTimeMillis() + ":time 2"); new Thread(new Runnable() { @Override public void run() { try { TimeUnit.SECONDS.sleep(3); } catch (Exception e) { //异常退出。 future.completeExceptionally(e); } // CompletableFuture被通知线程任务完成。 System.out.println(System.currentTimeMillis() + ":运行至此。"); future.complete("任务完成。"); } }).start(); System.out.println(System.currentTimeMillis() + ":time 3");

输出：

06-19 11:25:17.630 15068-15068/zhangphil.test I/System.out: 1529378717630:time 1 06-19 11:25:17.631 15068-15068/zhangphil.test I/System.out: 1529378717631:time 2 1529378717631:time 3 06-19 11:25:19.638 15068-15094/zhangphil.test I/System.out: 1529378719638:blog.csdn.net/zhangphil 06-19 11:25:20.634 15068-15095/zhangphil.test I/System.out: 1529378720633:运行至此。

可以看到在Thread线程体中的

future.complete("任务完成。");

没有执行，是因为在CompletableFuture.supplyAsync只休息了两秒，就正常执行完毕了，故不再执行complete的代码了。complete用来告知CompletableFuture任务完成。

下面调换sleep时间，让CompletableFuture.supplyAsync休息的长一些，而Thread里面休息短一下：

 CompletableFuture<String> future = CompletableFuture.supplyAsync(new Supplier<String>() { @Override public String get() { try { TimeUnit.SECONDS.sleep(3); } catch (Exception e) { e.printStackTrace(); } return "blog.csdn.net/zhangphil"; } }); System.out.println(System.currentTimeMillis() + ":time 1"); future.whenCompleteAsync(new BiConsumer<String, Throwable>() { @Override public void accept(String s, Throwable throwable) { System.out.println(System.currentTimeMillis() + ":" + s); } }); System.out.println(System.currentTimeMillis() + ":time 2"); new Thread(new Runnable() { @Override public void run() { try { TimeUnit.SECONDS.sleep(2); } catch (Exception e) { //异常退出。 future.completeExceptionally(e); } // CompletableFuture被通知线程任务完成。 System.out.println(System.currentTimeMillis() + ":运行至此。"); future.complete("任务完成。"); } }).start(); System.out.println(System.currentTimeMillis() + ":time 3");

输出：

06-19 11:32:26.814 16768-16768/zhangphil.test I/System.out: 1529379146814:time 1 06-19 11:32:26.815 16768-16768/zhangphil.test I/System.out: 1529379146815:time 2 06-19 11:32:26.816 16768-16768/zhangphil.test I/System.out: 1529379146816:time 3 06-19 11:32:28.818 16768-16820/zhangphil.test I/System.out: 1529379148818:运行至此。 06-19 11:32:28.822 16768-16854/zhangphil.test I/System.out: 1529379148822:任务完成。

这次没有输出字符串blog.csdn.net/zhangphil了，因为Thread率先执行完成，则直接以complete的结果为准，忽略CompletableFuture.supplyAsync的get计算结果。