completable-future

3열

1답변

Java 8 CompletableFuture에서 오류를 처리하는 방법은 무엇입니까?

Java에서 웹 소켓을 통해 간단한 RPC와 유사한 (또는 요청 - 응답) 시스템을 구현하려고합니다. 프론트 엔드에는 JS가 있지만 지금은 백엔드에서 작업하고 있습니다. 메시지를 비동기 적으로 처리하는 데 Java CompletableFuture 패턴을 적용하려고합니다. 그러나 나는 오류 처리에 열중하고있다. WebSocket 세션 (여기서는 Spring

0열

1답변

Java의 CompletableFuture 8

CompletableFuture가 Reactive Programming과 어떻게 관련되어 있다고 말할 수 있습니까? 다른 단어에서는 Java 8의 CompletableFuture를 사용하여 반응 원리를 구현할 수 있습니까?

0열

2답변

출력을 기다리지 않고 CompletableFuture를 어떻게 처리합니까?

CompletableFuture으로 재귀를 구현해야하는 상황이 있습니다. CompletableFuture 중 하나가 결과를 반환 할 때마다 recursionFuture(ex)으로 전화하고 싶지만 어떻게 구현해야할지 모르겠습니다. 현재 상황에서는 future1 및 future2이 출력을 반환하고 조건을 검사하는 경우에만 recursionFuture(ex)이

2열

1답변

CompletablFuture 및 ExecutorService와 병렬로 메서드 호출

getPrice 메서드에 대한 호출을 productproducts에 각각 호출하려고합니다. 이 코드 조각을 가지고 getPrice가 별도의 스레드에서 실행되고 있지만 순차적으로 병렬로 실행되고 있는지 확인했습니다. 아무도 내가 여기에서 놓치고있는 것을 지적 할 수 있습니까? 도움을 주셔서 감사합니다. ExecutorService service = Execu

6열

1답변

CompletableFuture의 flatMap과 동일한 기능이란 무엇입니까?

나는 이상한 타입의 CompletableFuture<CompletableFuture<byte[]>>을 가지고 있지만, 나는 CompletableFuture<byte[]>을 원한다. 이것이 가능한가? public Future<byte[]> convert(byte[] htmlBytes) { PhantomPdfMessage htmlMessage = ne

0열

1답변

CompletableFuture는 웹 서비스 호출을하고 모든 것이 완료되면 저장합니다.

각 세션에서 일부 속성을 설정하기 위해 webservice를 호출해야하는 세션 목록이 있습니다. async 프로세스를 사용하여 webservice를 호출하고 completablefuture를 사용하여 모든 작업이 완료되면 db로 저장할 수 있습니다. 어떻게하면됩니까? 지금까지, 내 코드는 다음과 같습니다, 그것은 작동하지 않습니다. sessions.st

2열

2답변

Java 8에서 thenCompose의 결과를 여러 번 사용하는 방법은 무엇입니까?

은 내가 getUserID 호출 내가 getProfile에 대한 다음 호출에 사용하십시오 CompletionStage<String>을 반환 myObject.updateDB(payload) .thenCompose(__ -> getUserID(payload.ID())) .thenCompose(id -> getProfile(id))

0열

1답변

여러 개의 thenApply in completableFuture

다른 스레드에서 일부 메서드를 실행하지만 한 스레드의 결과를 다른 스레드로 전달하려는 상황이 있습니다. 수업 시간에 다음과 같은 방법이 있습니다. 나는 인쇄 결과에 곱셈 뺄셈에 추가하여 결과를 전달하기 위해 노력하고 public static void main(String[] args) { int a = 10; int b = 5;

1열

2답변

사용 CompletableFuture 내가 가지고

안녕하세요 내가 CompletableFuture으로 생각하고 기본 ForkJoinPool 내가 고전 ExecutorService보다 더 많은 작업의 실행을 최적화 할 수있는 대기 스레드를 방지하지만 실행 1 초 정도이 코드와 함께 뭔가 누락 3 작업자 스레드 : for (int i = 0; i < 3; i++) { final int counter

2열

2답변

결과 또는 오류를 전파하는 동안 CompletableFuture 콜백을 호출하는 방법은 무엇입니까?

나는 예외적으로 .handle을 시도했지만 작동하지 않는 것 같습니다. 스칼라에서는 finally 블록과 같은 클로저를 사용하여 미래에 메서드를 호출 할 수 있습니다 (성공시 예외적으로 실행됩니다). 그리고 예외적으로 또는 성공한 체인을 그대로 전파합니다. 나는이 시도 ... CompletableFuture<Object> future = newFuture.