全新版FRIDA與安卓 應(yīng)用安全與逆向?qū)崙?zhàn)寶典

download：https://www.zxit666.com/6432/

1、CompletableFuture引見

CompletableFuture對(duì)象是JDK1.8版本新引入的類，這個(gè)類完成了兩個(gè)接口，一個(gè)是Future接口，一個(gè)是CompletionStage接口。

CompletionStage接口是JDK1.8版本提供的接口，用于異步執(zhí)行中的階段處置，CompletionStage定義了一組接口用于在一個(gè)階段執(zhí)行完畢之后，要么繼續(xù)執(zhí)行下一個(gè)階段，要么對(duì)結(jié)果停止轉(zhuǎn)換產(chǎn)生新的結(jié)果等，普通來說要執(zhí)行下一個(gè)階段都需求上一個(gè)階段正常完成，這個(gè)類也提供了對(duì)異常結(jié)果的處置接口

2、CompletableFuture的API

2.1 提交任務(wù)

在CompletableFuture中提交任務(wù)有以下幾種方式：

public static CompletableFuture<Void> runAsync(Runnable runnable)public static CompletableFuture<Void> runAsync(Runnable runnable, Executor executor)public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier)public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier, Executor executor)

這四個(gè)辦法都是用來提交任務(wù)的，不同的是supplyAsync提交的任務(wù)有返回值，runAsync提交的任務(wù)沒有返回值。兩個(gè)接口都有一個(gè)重載的辦法，第二個(gè)入?yún)橹付ǖ木€程池，假如不指定，則默許運(yùn)用ForkJoinPool.commonPool()線程池。在運(yùn)用的過程中盡量依據(jù)不同的業(yè)務(wù)來指定不同的線程池，便當(dāng)對(duì)不同線程池停止監(jiān)控，同時(shí)防止業(yè)務(wù)共用線程池互相影響。

2.2 結(jié)果轉(zhuǎn)換

2.2.1 thenApply

public ?CompletableFuture thenApply(Function<? super T,? extends U> fn)public ?CompletableFuture thenApplyAsync(Function<? super T,? extends U> fn)public ?CompletableFuture thenApplyAsync(Function<? super T,? extends U> fn, Executor executor)

thenApply這一組函數(shù)入?yún)⑹荈unction，意義是將上一個(gè)CompletableFuture執(zhí)行結(jié)果作為入?yún)?，再次停止轉(zhuǎn)換或者計(jì)算，重新返回一個(gè)新的值。

2.2.2 handle

public <U> CompletableFuture<U> handle(BiFunction<? super T, Throwable, ? extends U> fn)public <U> CompletableFuture<U> handleAsync(BiFunction<? super T, Throwable, ? extends U> fn)public <U> CompletableFuture<U> handleAsync(BiFunction<? super T, Throwable, ? extends U> fn, Executor executor)

handle這一組函數(shù)入?yún)⑹荁iFunction，該函數(shù)式接口有兩個(gè)入?yún)⒁粋€(gè)返回值，意義是處置上一個(gè)CompletableFuture的處置結(jié)果，同時(shí)假如有異常，需求手動(dòng)處置異常。

2.2.3 thenRun

public CompletableFuturethenRun(Runnable action)public CompletableFuturethenRunAsync(Runnable action)public CompletableFuturethenRunAsync(Runnable action, Executor executor)

thenRun這一組函數(shù)入?yún)⑹荝unnable函數(shù)式接口，該接口無需入?yún)⒑统鰠ⅲ@一組函數(shù)是在上一個(gè)CompletableFuture任務(wù)執(zhí)行完成后，在執(zhí)行另外一個(gè)接口，不需求上一個(gè)任務(wù)的結(jié)果，也不需求返回值，只需求在上一個(gè)任務(wù)執(zhí)行完成后執(zhí)行即可。

2.2.4 thenAccept

public CompletableFuture<Void> thenAccept(Consumer<? super T> action)public CompletableFuture<Void> thenAcceptAsync(Consumer<? super T> action)public CompletableFuture<Void> thenAcceptAsync(Consumer<? super T> action, Executor executor)

thenAccept這一組函數(shù)的入?yún)⑹荂onsumer，該函數(shù)式接口有一個(gè)入?yún)ⅲ瑳]有返回值，所以這一組接口的意義是處置上一個(gè)CompletableFuture的處置結(jié)果，但是不返回結(jié)果。

2.2.5 thenAcceptBoth

public ?CompletableFuturethenAcceptBoth(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)public ?CompletableFuturethenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action)public ?CompletableFuturethenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action, Executor executor)

thenAcceptBoth這一組函數(shù)入?yún)–ompletionStage以及BiConsumer，CompletionStage是JDK1.8新增的接口，在JDK中只要一個(gè)完成類：CompletableFuture，所以第一個(gè)入?yún)⒕褪荂ompletableFuture，這一組函數(shù)是用來承受兩個(gè)CompletableFuture的返回值，并將其組合到一同。BiConsumer這個(gè)函數(shù)式接口有兩個(gè)入?yún)?，并且沒有返回值，BiConsumer的第一個(gè)入?yún)⒕褪钦{(diào)用方CompletableFuture的執(zhí)行結(jié)果，第二個(gè)入?yún)⒕褪莟henAcceptBoth接口入?yún)⒌腃ompletableFuture的執(zhí)行結(jié)果。所以這一組函數(shù)意義是將兩個(gè)CompletableFuture執(zhí)行結(jié)果兼并到一同。

2.2.6 thenCombine

public <U,V> CompletableFuturethenCombine(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn)public <U,V> CompletableFuturethenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn)public <U,V> CompletableFuturethenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn, Executor executor)

thenCombine這一組函數(shù)和thenAcceptBoth相似，入?yún)⒍及粋€(gè)CompletionStage，也就是CompletableFuture對(duì)象，意義也是組合兩個(gè)CompletableFuture的執(zhí)行結(jié)果，不同的是thenCombine的第二個(gè)入?yún)锽iFunction，該函數(shù)式接口有兩個(gè)入?yún)?，同時(shí)有一個(gè)返回值。所以與thenAcceptBoth不同的是，thenCombine將兩個(gè)任務(wù)結(jié)果兼并后會(huì)返回一個(gè)全新的值作為出參。

2.2.7 thenCompose

public <U> CompletableFuture<U> thenCompose(Function<? super T, ? extends CompletionStage<U>> fn)public <U> CompletableFuture<U> thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn)public <U> CompletableFuture<U> thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn, Executor executor)

thenCompose這一組函數(shù)意義是將調(diào)用方的執(zhí)行結(jié)果作為Function函數(shù)的入?yún)?，同時(shí)返回一個(gè)新的CompletableFuture對(duì)象。

2.3 回調(diào)辦法

public CompletableFuturewhenComplete(BiConsumer<? super T, ? super Throwable> action)public CompletableFuturewhenCompleteAsync(BiConsumer<? super T, ? super Throwable> action)public CompletableFuturewhenCompleteAsync(BiConsumer<? super T, ? super Throwable> action, Executor executor)

whenComplete辦法意義是當(dāng)上一個(gè)CompletableFuture對(duì)象任務(wù)執(zhí)行完成后執(zhí)行該辦法。BiConsumer函數(shù)式接口有兩個(gè)入?yún)]有返回值，這兩個(gè)入?yún)⒌谝粋€(gè)是CompletableFuture任務(wù)的執(zhí)行結(jié)果，第二個(gè)是異常信息。表示處置上一個(gè)任務(wù)的結(jié)果，假如有異常，則需求手動(dòng)處置異常，與handle辦法的區(qū)別在于，handle辦法的BiFunction是有返回值的，而BiConsumer是沒有返回值的。

以上辦法都有一個(gè)帶有Async的辦法，帶有Async的辦法表示是異步執(zhí)行的，會(huì)將該任務(wù)放到線程池中執(zhí)行，同時(shí)該辦法會(huì)有一個(gè)重載的辦法，最后一個(gè)參數(shù)為Executor，表示異步執(zhí)行能夠指定線程池執(zhí)行。為了便當(dāng)停止控制，最好在運(yùn)用CompletableFuture時(shí)手動(dòng)指定我們的線程池。

2.4 異常處置

public CompletableFutureexceptionally(Function<Throwable, ? extends T> fn)

exceptionally是用來處置異常的，當(dāng)任務(wù)拋出異常后，能夠經(jīng)過exceptionally來停止處置，也能夠選擇運(yùn)用handle來停止處置，不過兩者有些不同，hand是用來處置上一個(gè)任務(wù)的結(jié)果，假如有異常狀況，就處置異常。而exceptionally能夠放在CompletableFuture處置的最后，作為兜底邏輯來處置未知異常。

2.5 獲取結(jié)果

public static CompletableFuture<Void> allOf(CompletableFuture<?>... cfs)public static CompletableFuture<Object> anyOf(CompletableFuture<?>... cfs)

allOf是需求入?yún)⒅幸磺械腃ompletableFuture任務(wù)執(zhí)行完成，才會(huì)停止下一步；

anyOf是入?yún)⒅腥魏我粋€(gè)CompletableFuture任務(wù)執(zhí)行完成都能夠執(zhí)行下一步。

public T get() throws InterruptedException, ExecutionExceptionpublic T get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutExceptionpublic T getNow(T valueIfAbsent)public T join()

get辦法一個(gè)是不帶超時(shí)時(shí)間的，一個(gè)是帶有超時(shí)時(shí)間的。

getNow辦法則是立刻返回結(jié)果，假如還沒有結(jié)果，則返回默許值，也就是該辦法的入?yún)ⅰ?/p>

join辦法是不帶超時(shí)時(shí)間的等候任務(wù)完成。

3、CompletableFuture原理

join辦法同樣表示獲取結(jié)果，但是join與get辦法有什么區(qū)別呢。

public T join() { ? ?Object r; ? ?return reportJoin((r = result) == null ? waitingGet(false) : r); }public T get() throws InterruptedException, ExecutionException { ? ?Object r; ? ?return reportGet((r = result) == null ? waitingGet(true) : r); }public T get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { ? ? ? ?Object r; ? ? ? ?long nanos = unit.toNanos(timeout); ? ? ? ?return reportGet((r = result) == null ? timedGet(nanos) : r); }public T getNow(T valueIfAbsent) { ? ? ? ?Object r; ? ? ? ?return ((r = result) == null) ? valueIfAbsent : reportJoin(r); }

以上是CompletableFuture類中兩個(gè)辦法的代碼，能夠看到兩個(gè)辦法簡直一樣。區(qū)別在于reportJoin/reportGet，waitingGet辦法是分歧的，只不過參數(shù)不一樣，我們?cè)诳聪聄eportGet與reportJoin辦法。

private static T reportGet(Object r) ? ? ? ?throws InterruptedException, ExecutionException { ? ? ? ?if (r == null) // by convention below, null means interrupted ? ? ? ? ? ?throw new InterruptedException(); ? ? ? ?if (r instanceof AltResult) { ? ? ? ? ? ?Throwable x, cause; ? ? ? ? ? ?if ((x = ((AltResult)r).ex) == null) ? ? ? ? ? ? ? ?return null; ? ? ? ? ? ?if (x instanceof CancellationException) ? ? ? ? ? ? ? ?throw (CancellationException)x; ? ? ? ? ? ?if ((x instanceof CompletionException) && ? ? ? ? ? ? ? ?(cause = x.getCause()) != null) ? ? ? ? ? ? ? ?x = cause; ? ? ? ? ? ?throw new ExecutionException(x); ? ? ? ?} ? ? ? ?@SuppressWarnings("unchecked") T t = (T) r; ? ? ? ?return t; ? ?}private static T reportJoin(Object r) { ? ? ? ?if (r instanceof AltResult) { ? ? ? ? ? ?Throwable x; ? ? ? ? ? ?if ((x = ((AltResult)r).ex) == null) ? ? ? ? ? ? ? ?return null; ? ? ? ? ? ?if (x instanceof CancellationException) ? ? ? ? ? ? ? ?throw (CancellationException)x; ? ? ? ? ? ?if (x instanceof CompletionException) ? ? ? ? ? ? ? ?throw (CompletionException)x; ? ? ? ? ? ?throw new CompletionException(x); ? ? ? ?} ? ? ? ?@SuppressWarnings("unchecked") T t = (T) r; ? ? ? ?return t; ? ?}

能夠看到這兩個(gè)辦法很相近，reportGet辦法判別了r對(duì)象能否為空，并拋出了中綴異常，而reportJoin辦法沒有判別，同時(shí)reportJoin拋出的都是運(yùn)轉(zhuǎn)時(shí)異常，所以join辦法也是無需手動(dòng)捕獲異常的。

我們?cè)诳聪聎aitingGet辦法

private Object waitingGet(boolean interruptible) { ? ? ? ?Signaller q = null; ? ? ? ?boolean queued = false; ? ? ? ?int spins = -1; ? ? ? ?Object r; ? ? ? ?while ((r = result) == null) { ? ? ? ? ? ?if (spins < 0) ? ? ? ? ? ? ? ?spins = SPINS; ? ? ? ? ? ?else if (spins > 0) { ? ? ? ? ? ? ? ?if (ThreadLocalRandom.nextSecondarySeed() >= 0) ? ? ? ? ? ? ? ? ? ?--spins; ? ? ? ? ? ?} ? ? ? ? ? ?else if (q == null) ? ? ? ? ? ? ? ?q = new Signaller(interruptible, 0L, 0L); ? ? ? ? ? ?else if (!queued) ? ? ? ? ? ? ? ?queued = tryPushStack(q); ? ? ? ? ? ?else if (interruptible && q.interruptControl < 0) { ? ? ? ? ? ? ? ?q.thread = null; ? ? ? ? ? ? ? ?cleanStack(); ? ? ? ? ? ? ? ?return null; ? ? ? ? ? ?} ? ? ? ? ? ?else if (q.thread != null && result == null) { ? ? ? ? ? ? ? ?try { ? ? ? ? ? ? ? ? ? ?ForkJoinPool.managedBlock(q); ? ? ? ? ? ? ? ?} catch (InterruptedException ie) { ? ? ? ? ? ? ? ? ? ?q.interruptControl = -1; ? ? ? ? ? ? ? ?} ? ? ? ? ? ?} ? ? ? ?} ? ? ? ?if (q != null) { ? ? ? ? ? ?q.thread = null; ? ? ? ? ? ?if (q.interruptControl < 0) { ? ? ? ? ? ? ? ?if (interruptible) ? ? ? ? ? ? ? ? ? ?r = null; // report interruption ? ? ? ? ? ? ? ?else ? ? ? ? ? ? ? ? ? ?Thread.currentThread().interrupt(); ? ? ? ? ? ?} ? ? ? ?} ? ? ? ?postComplete(); ? ? ? ?return r; ? ?}

該waitingGet辦法是經(jīng)過while的方式循環(huán)判別能否任務(wù)曾經(jīng)完成并產(chǎn)生結(jié)果，假如結(jié)果為空，則會(huì)不斷在這里循環(huán)，這里需求留意的是在這里初始化了一下spins=-1，當(dāng)?shù)谝淮芜M(jìn)入while循環(huán)的時(shí)分，spins是-1，這時(shí)會(huì)將spins賦值為一個(gè)常量，該常量為SPINS。

private static final int SPINS = (Runtime.getRuntime().availableProcessors() > 1 ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?1 << 8 : 0);

這里判別可用CPU數(shù)能否大于1，假如大于1，則該常量為 1<< 8，也就是256，否則該常量為0。

第二次進(jìn)入while循環(huán)的時(shí)分，spins是256大于0，這里做了減一的操作，下次進(jìn)入while循環(huán)，假如還沒有結(jié)果，仍然是大于0繼續(xù)做減一的操作，此處用來做短時(shí)間的自旋等候結(jié)果，只要當(dāng)spins等于0，后續(xù)會(huì)進(jìn)入正常流程判別。

我們?cè)诳聪聇imedGet辦法的源碼

private Object timedGet(long nanos) throws TimeoutException { ? ? ? ?if (Thread.interrupted()) ? ? ? ? ? ?return null; ? ? ? ?if (nanos <= 0L) ? ? ? ? ? ?throw new TimeoutException(); ? ? ? ?long d = System.nanoTime() + nanos; ? ? ? ?Signaller q = new Signaller(true, nanos, d == 0L ? 1L : d); // avoid 0 ? ? ? ?boolean queued = false; ? ? ? ?Object r; ? ? ? ?// We intentionally don't spin here (as waitingGet does) because ? ? ? ?// the call to nanoTime() above acts much like a spin. ? ? ? ?while ((r = result) == null) { ? ? ? ? ? ?if (!queued) ? ? ? ? ? ? ? ?queued = tryPushStack(q); ? ? ? ? ? ?else if (q.interruptControl < 0 || q.nanos <= 0L) { ? ? ? ? ? ? ? ?q.thread = null; ? ? ? ? ? ? ? ?cleanStack(); ? ? ? ? ? ? ? ?if (q.interruptControl < 0) ? ? ? ? ? ? ? ? ? ?return null; ? ? ? ? ? ? ? ?throw new TimeoutException(); ? ? ? ? ? ?} ? ? ? ? ? ?else if (q.thread != null && result == null) { ? ? ? ? ? ? ? ?try { ? ? ? ? ? ? ? ? ? ?ForkJoinPool.managedBlock(q); ? ? ? ? ? ? ? ?} catch (InterruptedException ie) { ? ? ? ? ? ? ? ? ? ?q.interruptControl = -1; ? ? ? ? ? ? ? ?} ? ? ? ? ? ?} ? ? ? ?} ? ? ? ?if (q.interruptControl < 0) ? ? ? ? ? ?r = null; ? ? ? ?q.thread = null; ? ? ? ?postComplete(); ? ? ? ?return r; ? ?}

timedGet辦法仍然是經(jīng)過while循環(huán)的方式來判別能否曾經(jīng)完成，timedGet辦法入?yún)橐粋€(gè)納秒值，并經(jīng)過該值計(jì)算出一個(gè)deadline截止時(shí)間，當(dāng)while循環(huán)還未獲取到任務(wù)結(jié)果且曾經(jīng)到達(dá)截止時(shí)間，則拋出一個(gè)TimeoutException異常。

4、CompletableFuture完成多線程任務(wù)

這里我們經(jīng)過CompletableFuture來完成一個(gè)多線程處置異步任務(wù)的例子。

這里我們創(chuàng)立10個(gè)任務(wù)提交到我們指定的線程池中執(zhí)行，并等候這10個(gè)任務(wù)全部執(zhí)行終了。

每個(gè)任務(wù)的執(zhí)行流程為第一次先執(zhí)行加法，第二次執(zhí)行乘法，假如發(fā)作異常則返回默許值，當(dāng)10個(gè)任務(wù)執(zhí)行完成后依次打印每個(gè)任務(wù)的結(jié)果。

<button type="button" class="btn btn-dark rounded-0 sflex-center copyCode" data-toggle="tooltip" data-placement="top" data-clipboard-text="public void demo() throws InterruptedException, ExecutionException, TimeoutException { // 1、自定義線程池 ExecutorService executorService = new ThreadPoolExecutor(5, 10, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(100)); // 2、匯合保管future對(duì)象 List<CompletableFuture> futures = new ArrayList<>(10); for (int i = 0; i < 10; i++) { int finalI = i; CompletableFuture?future = CompletableFuture // 提交任務(wù)到指定線程池 .supplyAsync(() -> this.addValue(finalI), executorService) // 第一個(gè)任務(wù)執(zhí)行結(jié)果在此處停止處置 .thenApplyAsync(k -> this.plusValue(finalI, k), executorService) // 任務(wù)執(zhí)行異常時(shí)處置異常并返回默許值 .exceptionally(e -> this.defaultValue(finalI, e)); // future對(duì)象添加到匯合中 futures.add(future); } // 3、等候一切任務(wù)執(zhí)行完成，此處最好加超時(shí)時(shí)間 CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).get(5, TimeUnit.MINUTES); for (CompletableFuture?future : futures) { Integer num = future.get(); System.out.println("任務(wù)執(zhí)行結(jié)果為：" + num); } System.out.println("任務(wù)全部執(zhí)行完成！"); } private Integer addValue(Integer index) { System.out.println("第" + index + "個(gè)任務(wù)第一次執(zhí)行"); if (index == 3) { int value = index / 0; } return index + 3; } private Integer plusValue(Integer index, Integer num) { System.out.println("第" + index + "個(gè)任務(wù)第二次執(zhí)行，上次執(zhí)行結(jié)果：" + num); return num * 10; } private Integer defaultValue(Integer index, Throwable e) { System.out.println("第" + index + "個(gè)任務(wù)執(zhí)行異常！" + e.getMessage()); e.printStackTrace(); return 10; } " aria-label="復(fù)制" data-bs-original-title="復(fù)制" style="margin: 0px; font-family: var(--bs-btn-font-family);font-size:undefined(--bs-btn-font-size); line-height: var(--bs-btn-line-height); appearance: button; --bs-btn-padding-x:0.75rem; --bs-btn-padding-y:0.375rem; --bs-btn-font-family: ; --bs-btn-font-size:1rem; --bs-btn-font-weight:400; --bs-btn-line-height:1.5; --bs-btn-color:#fff; --bs-btn-bg:#212529; --bs-btn-border-width:1px; --bs-btn-border-color:#212529; --bs-btn-border-radius:0.375rem; --bs-btn-hover-border-color:#373b3e; --bs-btn-box-shadow:inset 0 1px 0 hsla(0,0%,100%,0.15),0 1px 1px rgba(0,0,0,0.075); --bs-btn-disabled-opacity:0.65; --bs-btn-focus-box-shadow:0 0 0 0.25rem rgba(var(--bs-btn-focus-shadow-rgb),0.5); display: flex; padding: 0px; font-weight: var(--bs-btn-font-weight); vertical-align: middle; cursor: pointer; user-select: none; border: var(--bs-btn-border-width) solid var(--bs-btn-border-color); transition: color 0.15s ease-in-out 0s, background-color 0.15s ease-in-out 0s, border-color 0.15s ease-in-out 0s, box-shadow 0.15s ease-in-out 0s; --bs-btn-hover-color:#fff; --bs-btn-hover-bg:#424649; --bs-btn-focus-shadow-rgb:66,70,73; --bs-btn-active-color:#fff; --bs-btn-active-bg:#4d5154; --bs-btn-active-border-color:#373b3e; --bs-btn-active-shadow:inset 0 3px 5px rgba(0,0,0,0.125); --bs-btn-disabled-color:#fff; --bs-btn-disabled-bg:#212529; --bs-btn-disabled-border-color:#212529; justify-content: center; align-items: center; width: 1.5rem; height: 1.5rem; border-radius: 0px !important;">

public void demo() throws InterruptedException, ExecutionException, TimeoutException { ? ? ? ?// 1、自定義線程池 ? ? ? ?ExecutorService executorService = new ThreadPoolExecutor(5, 10, ? ? ? ? ? ? ? ?60L, TimeUnit.SECONDS, ? ? ? ? ? ? ? ?new LinkedBlockingQueue<>(100)); ? ? ? ?// 2、匯合保管future對(duì)象 ? ? ? ?List<CompletableFuture<Integer>> futures = new ArrayList<>(10); ? ? ? ?for (int i = 0; i < 10; i++) { ? ? ? ? ? ?int finalI = i; ? ? ? ? ? ?CompletableFuture<Integer> future = CompletableFuture ? ? ? ? ? ? ? ? ? ?// 提交任務(wù)到指定線程池 ? ? ? ? ? ? ? ? ? ?.supplyAsync(() -> this.addValue(finalI), executorService) ? ? ? ? ? ? ? ? ? ?// 第一個(gè)任務(wù)執(zhí)行結(jié)果在此處停止處置 ? ? ? ? ? ? ? ? ? ?.thenApplyAsync(k -> this.plusValue(finalI, k), executorService) ? ? ? ? ? ? ? ? ? ?// 任務(wù)執(zhí)行異常時(shí)處置異常并返回默許值 ? ? ? ? ? ? ? ? ? ?.exceptionally(e -> this.defaultValue(finalI, e)); ? ? ? ? ? ?// future對(duì)象添加到匯合中 ? ? ? ? ? ?futures.add(future); ? ? ? ?} ? ? ? ?// 3、等候一切任務(wù)執(zhí)行完成，此處最好加超時(shí)時(shí)間 ? ? ? ?CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).get(5, TimeUnit.MINUTES); ? ? ? ?for (CompletableFuture<Integer> future : futures) { ? ? ? ? ? ?Integer num = future.get();