try＆catch on supplyAsync

Question

私はCompletableFutureを初めて使うので、例外をスローするMetadataLoginUtil :: loginメソッドを呼びたいと思います。しかし、私は '例外的に'書かれているが、以下のコードはコンパイルされていません。これは、try & catch内でMetadataLoginUtil :: login 'をラップする必要があると言います。

お知らせください。 ありがとう！

public void run() throws ConnectionException { 
     CompletableFuture<Void> mt = CompletableFuture.supplyAsync(MetadataLoginUtil::login).exceptionally(e -> {System.out.println(e); return null; }).thenAccept(e -> System.out.println(e)); 
} 

Answer 1

CompletableFuture.supplyAsync(Supplier<U>)はjava.util.function.Supplier<U>インスタンスを期待し、Supplier.get()メソッドのシグネチャは、チェック例外を許可しません。これを明確に見るには、CompletableFuture.supplyAsync(MetadataLoginUtil::login)は、

CompletableFuture<Void> mt = CompletableFuture.supplyAsync(new Supplier<Void>() { 
     @Override 
     public Void get() { 
      return MetadataLoginUtil.login(); 
     } 
    }) 

と明らかにコンパイルできないことに注意してください。

あなたはそれはかなりありませんが、CompletableFutureのAPIは非常によくチェック例外では動作していないようCompletableFuture.supplyAsync(MetadataLoginUtil::login).exceptionally(e -> {System.out.println(e); return null; })

へ

CompletableFuture.supplyAsync(() -> { 
     try { 
      return MetadataLoginUtil.login(); 
     } catch (Exception e) { 
      System.out.println(e); 
      return null; 
     } 
    }) 

を変え、あなたのSupplier内の例外を処理することができます。

Answer 2

これは、CompletableFutureが一般的にどのように機能するのか不便ではありませんが、すべてがチェック例外を許可しない機能インターフェイスを使用しています。これは、基本的には、元のsupplyAsyncと同じようにやってますが、チェック例外を許可され

public static <T> CompletableFuture<T> supplyAsync(Callable<T> c) { 
    CompletableFuture<T> f=new CompletableFuture<>(); 
    CompletableFuture.runAsync(() -> { 
     try { f.complete(c.call()); } catch(Throwable t) { f.completeExceptionally(t); } 
    }); 
    return f; 
} 

：あなたは、代替 supplyAsyncの方法でこれを解決することができます。したがって、最初の試みのように使用して、最初の supplyAsyncコールをリダイレクトするだけです。

CompletableFuture<Void> mt = supplyAsync(MetadataLoginUtil::login) 
    .exceptionally(e -> { System.out.println(e); return null; }) 
    .thenAccept(e -> System.out.println(e));