ListeningExecutorService에서 예외를 throw하는 방법은 무엇입니까?

Question

내 프로젝트에서 Guava의 ListeningExecutorService를 사용했지만 예외 처리에 대해 혼란스러워했습니다.

스레드 풀을 사용하여 스레드 풀을 제출하고 listenableFuture에 시간 제한을 설정하고 콜백을 추가했습니다.

final ListeningExecutorService threadPool = MoreExecutors.listeningDecorator(Executors.newCachedThreadPool()); 



Futures.addCallback(listenableFuture, new FutureCallback<**>() { 

     @Override 
     public void onSuccess(@Nullable ** data) { 
      xxxxxxx; 
     } 

     public void onFailure(Throwable t) { 
      xxxxxxxxxx; 
      if (t instanceof CancellationException) { 
       throw new QueryException("yyyy"); 
      } else { 
       throw new QueryException("zzzzz"); 
      } 
     } 
    }); 

콜백 내부에서 예외를 catch 할 수 없습니다. 그래서 예외

ListenableFuture allFutures = Futures.allAsList(allFuturesList); 
     try { 
      allFutures.get(); 
     } catch (CancellationException ce) { 
      throw new QueryException(""); 
     } catch (InterruptedException t) { 
      throw new QueryException(""); 
     } catch (ExecutionException e) { 
      Throwable t = e.getCause(); 
      if (t instanceof QueryException) 
       throw (QueryException) t; 
      else 
       throw new QueryException(); 
     } catch (QueryException qe) { 
      throw qe; 
     } catch (Exception e) { 
      throw new QueryException(); 
     } finally { 
     } 

을 얻기 위해 다른 ListenableFuture를 사용하지만 콜백은 allFutures에만 자세한 오류 메시지없이 CancellationException를 잡을 수 있고, allFutures 그것을 잡을 수 없어하는 QueryException을 던질 때.

세부 정보 오류 메시지는 어떻게받을 수 있습니까?

Answer 1

Futures.allAsList 당신이는 자바 독에서

을 할 기대하지 않습니다

이 미래를 취소하는 모든 구성 요소 선물을 취소하려고 시도합니다 (강조는 나에게있다), 그리고 경우 제공된 선물 중 하나라도 실패하거나 이 취소 된 경우이 역시입니다.

당신이해야 할 일은 자신 만의 미래를 창출하는 것입니다. Guava의 내부 메커니즘을 기반으로 코드를 작성할 수 있습니다. 자세한 내용은 the source code을 참조하십시오.

어쨌든 이 아니며 예외를 던지려면 FutureCallback::onFailure 메서드를 사용하십시오.