Вопросы по теме 'completable-future'
CompletableFuture withFallback / обрабатывать только некоторые ошибки
Я получаю ответы на сервисный звонок через CompletableFuture. Я хотел бы обработать некоторые известные исключения, которые возвращает служба, например конфликты оптимистичного управления параллелизмом.
Вот что у меня есть. Есть ли лучший способ...
6759 просмотров
schedule
28.05.2023
Удивительное поведение Java 8 CompletableFuture исключительно методом
Я столкнулся со странным поведением метода Java 8 CompletableFuture.exceptionally. Если я выполняю этот код, он отлично работает и печатает java.lang.RuntimeException
CompletableFuture<String> future = new CompletableFuture<>();...
45072 просмотров
schedule
09.05.2023
Обработка исключений поставщика Java 8 с помощью CompletableFuture
Рассмотрим следующий код
public class TestCompletableFuture {
BiConsumer<Integer, Throwable> biConsumer = (x,y) -> {
System.out.println(x);
System.out.println(y);
};
public static void main(String args[]) {...
16407 просмотров
schedule
31.08.2022
Список ‹Future› в будущее ‹List› последовательность
Я пытаюсь преобразовать List<CompletableFuture<X>> в CompletableFuture<List<T>> . Это очень полезно, когда у вас много асинхронных задач и вам нужно получить результаты всех из них.
Если кто-то из них потерпит неудачу,...
38564 просмотров
schedule
26.01.2023
разделение огромного файла с помощью потоков
У меня есть текстовый файл, содержащий> 500 миллионов строк, и он структурирован следующим образом:
54517. lat:53.533459; lon:8.8005426; path:c:\brem_5.xml;
54518. lat:53.037579; lon:8.800404; path:c:\brem_5.xml;
54519. lat:53.03358275;...
47 просмотров
schedule
19.09.2022
Сопоставить исключение в завершаемом будущем с другим типом исключения?
Я использую завершаемые фьючерсы java 8, и я хотел бы иметь возможность принимать исключение, которое генерируется будущим, и преобразовывать его в другое исключение.
Кажется, что все составные элементы, которые я пробовал, замыкаются при...
1932 просмотров
schedule
24.03.2022
CompletableFuture с информацией об истекшем времени
Мне нужно иметь доступ к информации о времени выполнения асинхронного метода. Итак, я пытаюсь расширить CompletableFuture функциональность. Вот моя реализация с использованием шаблона декоратора :
import java.util.concurrent.*;
import...
3798 просмотров
schedule
27.04.2023
Java 8 поддерживает порядок потоков с помощью CompletableFuture::join
У меня есть входной поток запросов, которые выполняются асинхронно. Я хочу убедиться, что когда я использую Completablefuture::join , результат этих требований собирается в порядке входного потока запроса.
Вот как выглядит мой код:...
2498 просмотров
schedule
31.07.2022
Вернуть CompletableFuture ‹Void› или CompletableFuture ‹?›?
Я хочу написать асинхронный метод, который возвращает CompletableFuture . Единственная цель в будущем - отслеживать, когда метод завершен, а не его результат. Лучше вернуть CompletableFuture<Void> или CompletableFuture<?> ? Есть...
46164 просмотров
schedule
24.05.2024
CompletionStage: почему allOf или anyOf определено в CompletableFuture
У меня есть фреймворк, использующий интерфейс CompletionStage и мне любопытно, почему вспомогательные методы anyOf или allOf находятся в CompletableFuture определены там.
Похоже, они должны работать на интерфейсах, а не на реализации?
Я...
1925 просмотров
schedule
01.05.2023
Java 8 CompletableFuture.allOf() с коллекцией или списком
В Java 8 есть функция CompletableFuture.allOf(CompletableFuture<?>...cfs) , который возвращает CompletableFuture , который завершается, когда завершаются все заданные фьючерсы.
Однако я почти всегда имею дело не с массивом...
96791 просмотров
schedule
10.09.2022
Должен ли я использовать @Async для каждого метода службы, чтобы мое приложение полностью поддерживало асинхронность в Spring?
У меня есть очень простой контроллер:
@RequestMapping(value = "food", method = RequestMethod.POST)
public ResponseEntity<?> getAll(@RequestParam("term") String term) {
List<Food> foods =...
757 просмотров
schedule
05.09.2022
java многовложенный CompletionStage эквивалентен flatMap?
Итак, учитывая, что у меня есть следующий пример:
CompletionStage<String> tokenFuture = getToken();
CompletionStage<CompletionStage<CompletionStage<CompletionStage<Boolean>>>> result = tokenFuture.thenApply(token...
2970 просмотров
schedule
05.12.2022
CompletableFuture/parallelStream на сервере приложений JavaEE
Учитывая новую Java8, мы получаем действительно хорошие функции для асинхронных задач, например. CompletableFuture и .parallellStream(). Если вы запустите это в Java SE, как я понял, вы будете использовать ForkJoinPool, но что произойдет, если я...
2229 просмотров
schedule
13.10.2022
Как в java обработать CompletableFutures и получить первый желаемый результат?
Обычно с CompletableFuture я бы вызвал thenApply или какой-нибудь другой метод, чтобы что-то сделать, как только станет доступен результат. Однако теперь у меня есть ситуация, когда я хочу обрабатывать результаты, пока не получу положительный...
3298 просмотров
schedule
06.06.2022
Использование CompletionStage для возврата результатов
Я новичок в игре framework и Java8. Я пытаюсь написать простую веб-службу в Play, которая соответствует модели Asynch и позволяет быстро возвращать вызов веб-службы, оставляя тяжелую работу для асинхронного потока.
У меня очень простая операция...
5017 просмотров
schedule
13.02.2023
Одна задача CompletableFuture, которая продолжается множеством параллельных задач.
У меня есть следующий код:
return CompletableFuture.supplyAsync(() -> {
return foo; // some custom object
})
.thenAccept(foo -> {
// ??? need to spawn N async parallel jobs that works on 'foo'
});
На английском: первая задача...
5510 просмотров
schedule
05.06.2022
Объединение нескольких CompletableFuture
У меня есть следующий компонент:
private JobInfo aggregateJobInfo() {
final JobsResult jobsResult = restClient().getJobs();
final List<String> jobIds = extractJobIds(jobsResult);
//fetch details, exceptions and config for each...
12202 просмотров
schedule
13.07.2022
CompletableFutures и обработка исключений в Java
Я новичок во всем бизнесе CompletableFutures. В настоящее время я пытаюсь заполнить список фьючерсов объектами, полученными из вызова службы, а затем вернуть сам список. Однако я получаю ошибки error: unreported exception InvalidRequestException;...
106 просмотров
schedule
01.03.2023
Используйте CompletableFuture на ForkJoinpool и избегайте ожидания потока
Привет, я думал, что с CompletableFuture и значением по умолчанию ForkJoinPool я смогу оптимизировать выполнение задачи больше, чем классическое ExecutorService , но я кое-что упустил
С этим кодом выполнение занимает 1 секунду, у меня есть 3...
5317 просмотров
schedule
05.10.2022
