CompletableFuture避坑1——需要自定義線程池
CompletableFuture避坑2——allOf()超時時間不合理的后果
CompletableFuture避坑3——線程池的DiscardPolicy()導致整個程序卡死
CompletableFuture處理多線程任務(wù)時一般建議自定義線程池，線程池有個容量滿了的處理策略：
- ThreadPoolExecutor.DiscardPolicy()
- ThreadPoolExecutor.DiscardOldestPolicy()
- ThreadPoolExecutor.AbortPolicy()
- ThreadPoolExecutor.CallerRunsPolicy()
分別對應(yīng)： - 丟棄新提交的任務(wù)
- 丟棄等待中的最早的任務(wù)
- 拋異常，RejectedExecutionException
- 線程池不接任務(wù)，由提交任務(wù)的線程自己執(zhí)行
也可以自己實現(xiàn)RejectedExecutionHandler接口：
new RejectedExecutionHandler() {
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
log.error("xxx");
throw new RuntimeException();
}
});
可以拋出異常，可以忽略，也可以做其他處理。
用子線程執(zhí)行有兜底策略的任務(wù)（例如執(zhí)行失敗了使用默認數(shù)據(jù)等）時，如果線程池滿了，我們經(jīng)常會設(shè)置為打日志（不報警也不拋異常），統(tǒng)計失敗數(shù)量，失敗數(shù)量在一定范圍內(nèi)則忽略影響。這在以前是沒問題的。
開始使用jdk8的新API CompletableFuture 之后，CompletableFuture.allOf()方法或者get()方法等待所有CompletableFuture執(zhí)行完時，如果采用丟棄策略（包括自定義的不拋異常），則allOf()方法和get()方法會無限期的等待下去，即使allof()設(shè)置了orTimeout(2000, TimeUnit.MILLISECONDS)、get()使用get(2000, TimeUnit.MILLISECONDS)也不會超時結(jié)束。
