CompletableFutureでチェック例外が発生しました

Question

Java 8素晴らしいフィーチャーCompletableFutureを使用して、この新しいフィーチャーの例外を使用して古い非同期コードを変換したいと思います。しかし、チェックされた例外は私を悩ますものです。ここに私のコードです。

CompletableFuture<Void> asyncTaskCompletableFuture = 
       CompletableFuture.supplyAsync(t -> processor.process(taskParam)); 

processメソッドのシグネチャ：

public void process(Message msg) throws MyException; 

私はComletableFutureでそのチェック例外に対処するにはどうすればよいですか？

Answer 1

私はこの方法で試しましたが、問題を解決する良い方法かどうかはわかりません。

サプライヤーのFunctionalInterfaceで

@FunctionalInterface 
public interface RiskEngineFuncMessageProcessor<Void> extends Supplier<Void> { 
    @Override 
    default Void get() { 
     try { 
      return acceptThrows(); 
     } catch (final Exception e) { 
      throw new RuntimeException(e); 
     } 
    } 

    Void acceptThrows() throws Exception; 

、私は例外をラップすることができます。

final MyFuncProcessor<Void> func =() -> { 
      processor.process(taskParam); 
      return null; 
     }; 

     CompletableFuture<Void> asyncTaskCompletableFuture = 
       CompletableFuture.supplyAsync(func) 
         .thenAccept(act -> { 
          finishTask(); 
         }) 
         .exceptionally(exp -> { 
          log.error("Failed to consume task", exp); 
          failTask(exp.getMessage()); 
          return null; 
         });