JDK8 CompletableFuture.supplyAsync interruptedException을 처리하는 방법

Question

CompletableFuture.supplyAsync(
() -> { 
    transporter.write(req); 
    //here take the value from a blocking queue,will throw a interruptedException 
    return responseQueue.take(); 
}, executorService); 

interruptedException을 처리하는 일반적인 방법은 다시 인터럽트하거나 interruptedException을 throw하는 것이지만 둘 다 작동하지 않습니다. 누구나 아이디어가 있으십니까?

Answer 1

나는 이와 같은 코드를 변경합니다.

CompletableFuture<Rep> result = new CompletableFuture<>(); 
    CompletableFuture.runAsync(() -> { 

     transporter.write(req); 
     try { 
      Rep rep = responseQueue.take(); 
      result.complete(rep); 
     } catch (InterruptedException e) { 
      result.completeExceptionally(e); 
      Thread.currentThread().interrupt(); 
     } catch (Exception e) { 
      result.completeExceptionally(e); 
     } 

    }, executorService); 
    return result; 

Answer 2

람다 함수는 예외를 throw하는 것을 지원하지 않으므로 Java 개발자는 새로운 패러다임이 필요하다고 생각합니다. 한 가지 생각하면 다음과 같습니다 :

람다 함수는이 래퍼의 인스턴스를 반환 할 수 있습니다. (편집 : 귀하의 사례)

CompletableFuture<ResultWrapper<String, InterruptedException>> aFuture = ...; 
... 
aFuture.supplyAsync(
() -> { 
    try { 
     transporter.write(req); 
    } catch(InterruptedException e) { 
     ResultWrapper<String, InterruptedException> r = new ResultWrapper<>(); 
     r.exception = e; 
     r.result = null; 
     return r; 
    } 
    ... 
}, executorService); 

Answer 3

나는 같은 질문으로 실행하지만, 더 여기 의견과 참고 도서에서 읽은 후 나는 당신이 이들 중 하나를 수행 할 수 있다고 생각 :

이

1 (I은 결국 무엇 일) :

를

CompletableFuture.runAsync(() -> { 
    transporter.write(req); 
    try { 
     Rep rep = responseQueue.take(); 
     result.complete(rep); 
    } catch (Exception e) { 
     throw new CompletionException(e); 
    } 
}, executorService); 
return result; 

또는 2 :

CompletableFuture<Rep> result = new CompletableFuture<>(); 
new Thread(()-> { 
    transporter.write(req); 
    try { 
     Rep rep = responseQueue.take(); 
     result.complete(rep); 
    } catch (Exception e) { 
     retsult.completeExceptionally(e); 
    } 
}).start(); 

나는 2 일이 executorService를 사용하지 않습니다 알고 있지만, CompletableFuture를 사용하는 전체 요점이 기능 스타일로 CompletionStage API를 활용하고 있다고 생각합니다.