completable-future

1열

1답변

컨텍스트 스레드에서 CompletableFuture # whenComplete 실행을 방지하는 방법

나는 다음과 같은 코드가 있습니다 ConcurrentHashMap taskMap= new ConcurrentHashMap(); .... taskMap.compute(key, (k, queue) -> { CompletableFuture<Void> future = (queue == null) ? CompletableFuture.ru

3열

2답변

join(), get()을 사용한 CompletableFuture 예외 동작

내 직감은 다음 코드가 잘못되었다는 것입니다. 나는 join()이 사용 되었기 때문에 미래를 완료하는 동안 어떤 예외도 던지지 않는다고 믿는다. 그런 다음 get()이 호출되면 검사 예외가 발생하지 않으며 오류가 로깅되지 않으며 오류 발생시 오류를 진단하기 어려워집니다. List<CompletableFuture> list = ImmutableList.of(

0열

2답변

자바 completable 선물과

체인 예외 나는 다음과 같은 코드를 가지고 processNotFound뿐만 아니라 그 실패 할 수있는 CompletableFuture을 반환 return future.exceptionally(t -> { if(t instanceof NotFoundException) return processNotFound(responseCb, req

0열

1답변

스프링 데이터 JPA 내 엔티티 비동기를 저장하고 결과의 미래를 반환하려고

미래를 반환하지만, 나는 다음과 같은 문제가 있었다 내 저장소를 비동기 저장소로 구현하고 테스트하는 방법은 무엇입니까? 더 나은 성능을 가진 접근 방식은 다음과 같습니다. 1. 저장소에서 선물을 반환하십시오. 2. ExecutorService에서 호출 가능 저장소 메소드를 실행 하시겠습니까?

-3열

2답변

루프에서 completable future를 호출하고 모든 결과를 결합하는 방법은 무엇입니까?

나는 이와 같은 것을 달성하려고 노력하고있다. 이것은 의도를 표현한 구성 예입니다. 모든 완료 가능한 미래를 실행하고 모든 결과를 하나의 결과로 결합하여 반환해야합니다. 따라서 아래 예제에서 컬렉션 allResults는 "one", "two", "three"라는 문자열을 각각 3 번 가져야합니다. 나는 그들 모두가 연속적이지 않고 평행하게 달리고 싶다. 완

5열

1답변

CompletableFuture.thenAccept가 실제로 차단할 수 있습니다.

I can't emphasize this enough: thenAccept()/thenRun() methods do not block과 같은 일부 블로그에서와 달리 CompletableFuture.thenAccept은 실제로 차단할 수 있습니다. pause 메서드 호출이 thenAccept 차단하게됩니다 주석을 해제, 다음 코드를 고려하십시오 Complet

4열

2답변

이미 완료된 CompletableFuture를 작성하는 올바른 방법은 무엇입니까 <Void>

Java 8에서 Completable future를 사용하고 있으며 수신 된 매개 변수에 따라 부작용이있는 여러 작업을 병렬로 실행 한 다음 (CompletableFuture.allOf()을 사용하여) "결합 된"미래를 반환하거나 아무것도하지 않고 이미 완료된 미래를 반환합니다. 그러나, allOf는 CompletableFuture<Void> 반환 : pu

0열

1답변

는 CompletableFuture 여러 콜백 실행에 참여

나는 다음과 같은 작업 코드가 있습니다 DiscoveryCallback callback = new DiscoveryCallback(); Manager.discover(someparam, callback); 내가 다른 비동기 작업으로 구성 할 수있는 수신 틱 API를 위해 CompletableFuture에이 호출을 래핑 할을. Manager.discov

-1열

2답변

방법 (CompletableFuture를 사용하여 만든) 각 asynchronus 호출 여기

에 대한 클래스의 새로운 인스턴스를 생성하는 것은 내 코드입니다 : class A{ @Autowired B objB; public method1(){ List<String> ids = new ArrayList<String>(); ids.add("1"); ids.add("2"); ids.

0열

1답변

봄을 기다리십시오 ListenableFuture

휴식 전화를 보내기 위해 봄 AsyncRestTemplate을 사용하는 서비스가 있습니다. AsyncRestTemplate.exchange()의 각 호출은 ListenableFuture을 반환합니다. 이런 식으로 뭔가 : ListenableFuture future1 = new AsyncRestTemplate().exchange(...); Liste