cyclops-react와 async-retry : 타임 아웃시 재 시도하는 방법?

Question

나는 cyclops-react를 async-retry와 함께 사용하기 시작했습니다. 나는 아직도 그걸로 길을 잃었습니다.

나는 SimpleReact를 사용하여 서버에서 타임 아웃을 시뮬레이션하지만 난 결코 이런 일에 시간 제한받지 해요 : 거기에 어떤 누락

private List<Object> executeParallel() { 
    List<Object> result = new SimpleReact(mainThreadPool) 
      .of(getSupplier()) 
      .withRetrier(new AsyncRetryExecutor(retryThreadPool) 
        .abortIf((t) -> !TimeoutException.class.isAssignableFrom(t.getClass())) 
      ) 
      .retry(retrySupplier()) 
      .block() 
      .collect(Collectors.toList()); 
    return result; 
} 

private Supplier getSupplier() { 
    return() -> someOperationThatTimesOut(); 
} 

private Function<Supplier, Object> retrySupplier() { 
    return supplier -> supplier.get(); 
} 

를?

Answer 1

이 버전은

AtomicInteger count = new AtomicInteger(0); 

@Test 
public void executeParallel() { 
    List<Object> result = new SimpleReact(Executors.newFixedThreadPool(1)) 
      .of(getSupplier()) 
      .withRetrier(new AsyncRetryExecutor(Executors.newScheduledThreadPool(1)) 
      .retry(Supplier::get) 
      .block() 
      .collect(Collectors.toList()); 
    System.out.println(result); 
} 

private Supplier<String> getSupplier() { 
    return() -> { 
     System.out.println("Attempt " + count.incrementAndGet()); 
     if(count.get()<4) 
      throw ExceptionSoftener.throwSoftenedException(new TimeoutException()); 
     return "success"; 
    }; 
} 

작동 내가 당신이 비동기 retrier에 abortIf 필요하지 않습니다 의심

Attempt 1 
Attempt 2 
Attempt 3 
Attempt 4 
[success] 

을 출력 할 것이다, 나는 내부에 무슨 일이 일어나고 있는지 확실하지 않다 someOperationThatTimesOut() - 여기 키가 될 수 있습니다.