CompletableFuture List ждет всех будущих выпусков - PullRequest
Новая
       23

CompletableFuture List ждет всех будущих выпусков

0 голосов
/ 26 апреля 2019

У меня есть следующий список конвейера CompletableFuture 

for (Integer unit : getIds()) {
        futureList.add(CompletableFuture.completedFuture(unit)
            .thenApply(id -> CompletableFuture
                .completedFuture(service.get1(id))
                .thenCombineAsync(CompletableFuture.completedFuture(b), (a, df1) -> 
                    CompletableFuture.completedFuture(service.validate(Optional.ofNullable(a),c, 
                            b, dealerCode))
                    .thenApplyAsync(status -> CompletableFuture.completedFuture(b))
                    .thenCombineAsync(CompletableFuture.completedFuture(a), (b1, a1) -> 
                        service.mapToTrans(Optional.ofNullable(a), b, c))
                    .handle((response, exception) -> {
                        if(exception == null) {
                            return response;
                        }
                        else {
                            handler.handleException(exception, results);
                            return null;
                        }
                    })
                    .thenApplyAsync(t -> service.submitRequest(Optional.ofNullable(a), c))
                    .thenApplyAsync((t) -> service.saveTransaction(Optional.ofNullable(t)))
                    .thenAccept(result1 -> results.add(result1))
                )
                .handle((response, exception) -> handleStage(response, exception, results))
            )
            .handle((response, exception) -> handleStage(response, exception, results))
            );
    }

Массив результатов содержит результаты всех фьючерсов.В основном методе так я жду завершения всех фьючерсов 

CompletableFuture<Void> allFutures = CompletableFuture
            .allOf(futureList.toArray(new CompletableFuture[futureList.size()]));
CompletableFuture<List<Object>> allFutureExec = allFutures.thenApply(v -> {
            return futureList.stream().map(pg-> pg.join()).collect(Collectors.toList());
        });
allFutureExec.get();

Предполагается, что список «результатов» будет содержать результаты всей будущей цепочки. Но я вижу, что основной поток нев ожидании всех этапов, которые будут выполнены.Список результатов имеет результат только нескольких фьючерсов, хотя из журналов видно, что все фьючерсы исполняются.Пожалуйста, дайте мне знать, если это правильный способ ожидания завершения всех фьючерсов.

ОБНОВЛЕНИЕ-1 

for (Integer unit : getIds()) {
        futureList.add(CompletableFuture
                .completedFuture(service.get1(unit))
                .thenCombine(CompletableFuture.completedFuture(td), (vd, dealerInfo1) -> 
                    CompletableFuture.completedFuture(service.validate(Optional.ofNullable(vd),sd, 
                        td))
                    .thenApply(status -> CompletableFuture.completedFuture(service.mapToTrans
                            (Optional.ofNullable(vd), td,trade, userCredential))
                    .thenApplyAsync(transaction -> CompletableFuture.completedFuture(service.submit(Optional.ofNullable(vd),transaction))
                    .thenApply((transaction1) -> service.saveTransaction(Optional.ofNullable(transaction1)))
                    .thenApply(result1 -> results.add(result1)))))
        );      

    }
...