文章目錄

• Code

---

Code

Future 接口 的局限性有很多，其中一個就是需要主動的去詢問是否完成，如果等子線程的任務(wù)完成以后，通知我，那豈不是更好？

public class FutureInAction3 {public static void main(String[] args) {Future<String> future = invoke(() -> {try {Thread.sleep(10000L);return "I am Finished.";} catch (InterruptedException e) {return "I am Error";}});future.setCompletable(new Completable<String>() {@Overridepublic void complete(String s) {System.out.println("complete called ---- " + s);}@Overridepublic void exception(Throwable cause) {System.out.println("error");cause.printStackTrace();}});System.out.println("....do something else .....");System.out.println("try to get result ->" + future.get());}private static <T> Future<T> invoke(Callable<T> callable) {AtomicReference<T> result = new AtomicReference<>();AtomicBoolean finished = new AtomicBoolean(false);Future<T> future = new Future<T>() {private Completable<T> completable;@Overridepublic T get() {return result.get();}@Overridepublic boolean isDone() {return finished.get();}// 設(shè)置完成@Overridepublic void setCompletable(Completable<T> completable) {this.completable = completable;}// 獲取@Overridepublic Completable<T> getCompletable() {return completable;}};Thread t = new Thread(() -> {try {T value = callable.action();result.set(value);finished.set(true);if (future.getCompletable() != null)future.getCompletable().complete(value);} catch (Throwable cause) {if (future.getCompletable() != null)future.getCompletable().exception(cause);}});t.start();return future;}private interface Future<T> {T get();boolean isDone();// 1void setCompletable(Completable<T> completable);// 2Completable<T> getCompletable();}private interface Callable<T> {T action();}// 回調(diào)接口private interface Completable<T> {void complete(T t);void exception(Throwable cause);} }

總結(jié)

以上是生活随笔為你收集整理的Java8 - 自定义实现体会CompletableFuture的原理的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。