Как выполнить асинхронно часть метода?

Question

[Олег Михайлов]

Опишу сразу структуру с которой имеем дело:
1. Есть асинхронный контроллер (с выделенным THREAD_POOL_EXECUTOR) возвращающий CompletableFuture.
2. Внутри этого контроллера выполняется логика и в середине этого выполнения необходимо отправить, например, 5 http запросов, получить их результат и продолжить выполнять логику контроллера.

Есть проблема именно в месте, где отправляются эти запросы - выполняется очень медленно всё.

Отправка вот:

RequestSendManager manager = new RequestSendManager();
            DeferredResult<Map<BaseProtocol, RequestData>> res = manager
                .sendToPool(dspDatas);
            Map<BaseProtocol, RequestData> result =
                (Map<BaseProtocol, RequestData>) res.getResult();

Как можно в этом месте сделать это асинхронно, не блокируя этим действием основной поток обработки, т.к. в этот момент приходят ещё запросы в этот контроллер и поток надо временно освободить, пока не будет получен результат из этих http ответов и продолжить выполнение логики?

Answer 1

[Олег Михайлов]

Кому интересно, то проблема решена следующим образом:

ExecutorService pool = Executors.newFixedThreadPool(dspMap.size());
            List<Callable<BaseProtocol>> todo = new ArrayList<>(5);
dspMap.forEach((name, httpRequest) -> {
                todo2.add(() -> httpRequest.send());
 });
            try {
                List<Future<BaseProtocol>> res = pool.invokeAll(todo2);

                res.forEach(v -> {
                        //тут в res лежат уже все ответы, а время на выполнение всех запросов будет таким, 
                       //сколько займёт самый долгий ответ
                });

Answer 2

[Dmtm]

почему запросы выполняются в контроллере а не в самом CompletableFuture?
примерно так:
CompletableFuture.supplyAsync(...)
.exceptionally(....)
.thenApply(....)
.thenAccept(....);

Comments

[Олег Михайлов]

Не знаю, как продолжить выполнение с учётом этой конструкции, т.к. контроллер должен ведь вернуть ответ какой-то

[Dmtm]

Олег Михайлов, контроллер вернет CompletableFuture которую создаст, сразу же как только создаст, дальше не его дело как именно выполняется задача

Answer 3

[Ерлан Ибраев]

Future?!

Comments

[Олег Михайлов]

Не освобождает поток, т.к. метод get() у Future является блокирующим