先看看ExecutorService中的這幾個(gè)方法
public interface ExecutorService extends Executor {
//不再接受新任務(wù)泉手，待所有任務(wù)執(zhí)行完畢后關(guān)閉ExecutorService
void shutdown();
//不再接受新任務(wù)，直接關(guān)閉ExecutorService偶器，返回沒(méi)有執(zhí)行的任務(wù)列表
List<Runnable> shutdownNow();
//判斷ExecutorService是否關(guān)閉
boolean isShutdown();
//判斷ExecutorService是否終止
boolean isTerminated();
//等待ExecutorService到達(dá)終止?fàn)顟B(tài)
boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException;
<T> Future<T> submit(Callable<T> task);
//當(dāng)task執(zhí)行成功的時(shí)候future.get()返回result
<T> Future<T> submit(Runnable task, T result);
//當(dāng)task執(zhí)行成功的時(shí)候future.get()返回null
Future<?> submit(Runnable task);
//批量提交任務(wù)并獲得他們的future斩萌，Task列表與Future列表一一對(duì)應(yīng)
<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
throws InterruptedException;
//批量提交任務(wù)并獲得他們的future，并限定處理所有任務(wù)的時(shí)間
<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
long timeout, TimeUnit unit) throws InterruptedException;
//批量提交任務(wù)并獲得一個(gè)已經(jīng)成功執(zhí)行的任務(wù)的結(jié)果
<T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException;
<T> T invokeAny(Collection<? extends Callable<T>> tasks,
long timeout, TimeUnit unit)
throws InterruptedException, ExecutionException, TimeoutException;
}
應(yīng)用場(chǎng)景
- invokeAny
需求描述:海量數(shù)據(jù)文件系統(tǒng),我們需要找出其中某個(gè)資源(可以確定的是,該文件系統(tǒng)的資源都是唯一的)
我們可能啟動(dòng)多個(gè)線程去各自負(fù)責(zé)自己的區(qū)域屏轰，比如線程A負(fù)責(zé)Area_A,線程B負(fù)責(zé)Area_B,這樣可以大規(guī)模的提升速度颊郎。但是我們希望只要其中一個(gè)線程找到符合要求的數(shù)據(jù)時(shí) 我們就立即返回,而不用還讓其他線程繼續(xù)執(zhí)行下去,這樣可以節(jié)省CPU使用率。而invokeAny就可以很好的解決這個(gè)問(wèn)題,只要其中一個(gè)線程執(zhí)行完了,就會(huì)立即返回,其他線程就會(huì)退出,不在占用cpu資源霎苗。
- invokeAll
需求描述:海量數(shù)據(jù)文件系統(tǒng)的搜索功能,但和上面的不同,里面存在多個(gè)相似的資源,需要全部查出來(lái)姆吭。
-
invokeAll超時(shí)方法
image.png
在指定的時(shí)間范圍內(nèi),如果沒(méi)有執(zhí)行完,則取消沒(méi)有執(zhí)行完的任務(wù)。
相關(guān)測(cè)試DEMO請(qǐng)參考:https://github.com/jerrik123/ExecutorService_invokeAll_Any
