先看看ExecutorService中的這幾個(gè)方法

public interface ExecutorService extends Executor {  

    //不再接受新任務(wù)，待所有任務(wù)執(zhí)行完畢后關(guān)閉ExecutorService  
    void shutdown();  

    //不再接受新任務(wù)，直接關(guān)閉ExecutorService，返回沒有執(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)景

1. 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è)問題,只要其中一個(gè)線程執(zhí)行完了,就會(huì)立即返回,其他線程就會(huì)退出,不在占用cpu資源。

2. invokeAll

需求描述:海量數(shù)據(jù)文件系統(tǒng)的搜索功能,但和上面的不同,里面存在多個(gè)相似的資源,需要全部查出來。

3. invokeAll超時(shí)方法

   
   
   image.png
   
   

   在指定的時(shí)間范圍內(nèi),如果沒有執(zhí)行完,則取消沒有執(zhí)行完的任務(wù)。

相關(guān)測(cè)試DEMO請(qǐng)參考:https://github.com/jerrik123/ExecutorService_invokeAll_Any