completablefuture参加対CompletableFuture.get（）とCompletableFuture.join（）の違い</p> <p>以下は私のコードでは何

Question

を得る：

List<String> process() { 

    List<String> messages = Arrays.asList("Msg1", "Msg2", "Msg3", "Msg4", "Msg5", "Msg6", "Msg7", "Msg8", "Msg9", 
      "Msg10", "Msg11", "Msg12"); 
    MessageService messageService = new MessageService(); 
    ExecutorService executor = Executors.newFixedThreadPool(4); 

    List<String> mapResult = new ArrayList<>(); 

    CompletableFuture<?>[] fanoutRequestList = new CompletableFuture[messages.size()]; 
    int count = 0; 
    for (String msg : messages) { 
     CompletableFuture<?> future = CompletableFuture 
       .supplyAsync(() -> messageService.sendNotification(msg), executor).exceptionally(ex -> "Error") 
       .thenAccept(mapResult::add); 

     fanoutRequestList[count++] = future; 
    } 

    try { 
     CompletableFuture.allOf(fanoutRequestList).get(); 
     //CompletableFuture.allOf(fanoutRequestList).join(); 
    } catch (InterruptedException | ExecutionException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } 

    return mapResult.stream().filter(s -> !s.equalsIgnoreCase("Error")).collect(Collectors.toList()); 
} 

私は両方の方法を試してみましたが、違いはありませんでは、結果。

ありがとう

Answer 1

例外は例外をスローする方法です。 get()は例外がは、彼らがあなたのコードで処理する必要があることを意味例外をチェックされ、両方の

V get() throws InterruptedException, ExecutionException; 

としてFutureインタフェースで宣言されています。あなたのコードで見ることができるように、IDEの自動コードジェネレータは、あなたのためにtry-catchブロックを作成するかどうか尋ねました。

try { 
    CompletableFuture.allOf(fanoutRequestList).get() 
} catch (InterruptedException | ExecutionException e) { 
    // TODO Auto-generated catch block 
    e.printStackTrace(); 
} 

join()方法はがチェック例外をスローしません。

public T join() 

代わりに、それは未チェック CompletionExceptionをスローします。あなたは両方のget()とjoin()実装here