Вопросы по теме 'completable-future'

преобразовать список завершаемых фьючерсов в одно завершаемое будущее списка
У меня есть список CompletableFuture экземпляров. List<CompletableFuture<String>> listOfFutures; Как преобразовать их в одно будущее, как это: CompletableFuture<List<String>> futureOfList =...
2454 просмотров
schedule 06.01.2023

Java 8 CompletableFuture против Netty Future
Как CompletableFuture , введенный в JDK 8, сравнивается с io.netty.util.concurrent.Future , предоставленным Netty? В документации Netty упоминается, что JDK 8 добавляет CompletableFuture, который несколько перекрывает...
3181 просмотров

CompletionStage: вернуть CompletionStage в исключительном блоке
Есть ли способ вернуть новый CompletionStage в случае возникновения исключения? API для exceptionally , похоже, не позволяет вам это сделать. Есть ли способ обойти это? По сути, я хотел бы сделать flatMap ( thenCompose ) для случая...
155 просмотров
schedule 24.01.2023

Отдельная обработка исключений CompletableFuture
Я понимаю, что хотел бы, чтобы пользователям нашего API не приходилось обрабатывать исключения. Или, может быть, более ясно, я хотел бы убедиться, что исключение всегда регистрируется, но только потребитель будет знать, как справиться с успехом. Я...
13218 просмотров
schedule 10.06.2023

Как получить CompletableFuture‹T› из запроса асинхронного Http-клиента?
В документации по асинхронному Http-клиенту я вижу, как получить Future<Response> в результате асинхронного HTTP. Получить запрос, просто выполнив, например: AsyncHttpClient asyncHttpClient = new DefaultAsyncHttpClient();...
9134 просмотров

Пользовательские исполнители PlayFramework при использовании CompletableFutures и java
В последних версиях PlayFramework они начали использовать CompletionStage в качестве типа возвращаемого значения для контроллеров, которые будут использоваться для асинхронного выполнения, или, в двух словах, если вы возвращаете CompletionStage ,...
758 просмотров

Как мне продолжить CompletableFuture, не дожидаясь вывода
У меня возникла ситуация, когда мне нужно реализовать рекурсию с CompletableFuture . Я хочу вызывать recursionFuture(ex) всякий раз, когда любой из CompletableFuture возвращает какой-либо результат, но я не уверен, как это реализовать. В...
1449 просмотров

Java Future — Spring Authentication не имеет значения для AuditorAware
Это мой сценарий: В моем приложении включен аудит Mongo с пользовательским AuditorAware, который получает текущего пользователя из файла SecurityContext . Это хорошо работает с синхронными методами, и текущий аудитор успешно сохраняется, но я не...
3817 просмотров

Должен ли API возвращать CompletionStage или CompletableFuture
При создании API рекомендуется кодировать интерфейс, поэтому кажется, что возврат CompletionStage кажется лучшим подходом. Однако я понял, что всегда вызываю .toCompletableFuture после получения CompletionStage. Каков рекомендуемый подход в этом...
1581 просмотров

Как я могу перехватить исключение RejectedExecutionException, созданное при вызове комплететаблефутуре комплетеасинк?
В следующем примере кода я ввожу biconsumer , который спит в течение 100 миллисекунд, как действие завершения набора завершаемого будущего. Я использовал метод whenCompleteAsync , предоставив для использования отдельный executorService ....
1885 просмотров

Завершаемые фьючерсы Java 8 для всех типов данных
У меня есть 3 CompletableFutures, все 3 возвращают разные типы данных. Я хочу создать объект результата, который представляет собой композицию результата, возвращаемого всеми тремя фьючерсами. Итак, мой текущий рабочий код выглядит так:...
5613 просмотров
schedule 12.12.2023

Ожидая одинаковых результатов от этих двух CompletableFuture
Однако testCase2 не обрабатывает исключение и выдает ошибку. Я что-то упускаю? Извините, если я сделал, совершенно новичок в этом. @Test public void testCase1() throws Exception { CompletableFuture.supplyAsync(() -> { if (true)...
88 просмотров
schedule 07.05.2023

Синхронное поведение при использовании методов Java CompletableFuture
Я использую Java CompletableFuture в весенней загрузке @Service : @Service public class ProcessService { private static final ExecutorService EXECUTOR = Executors.newFixedThreadPool(3); @Autowired ChangeHistoryService...
759 просмотров

Наращивание памяти при использовании CompletableFuture
class DataItemCache { private CompletableFuture future; public DataItemCache() { future = CompletableFuture.completedFuture(null); } public void saveItemAsync(Object dataItem) { future = future.thenRunAsync(() ->...
2529 просмотров
schedule 16.01.2023

Когда использовать неасинхронные методы CompletableFuture?
Я (в основном) понимаю три метода выполнения CompletableFuture : неасинхронный ( синхронное выполнение ) async по умолчанию (асинхронный с использованием исполнителя по умолчанию) настраиваемый асинхронный режим (асинхронный с использованием...
1661 просмотров
schedule 05.05.2023

Как слушать асинхронный Java-контроллер на стороне сервера?
Погуглив это, я наткнулся на множество примеров, одним из которых был $q из Angular, чтобы избежать рекурсивного обращения к моей серверной части, чтобы проверить, заполнен ли запрос данными или нет. Я наткнулся на эту ссылку:...
472 просмотров

CompletableFuture — укажите метод, который возвращает логическое значение для вызова SupplyAsync.
Я возвращаюсь к Java после долгого времени, поэтому прошу прощения, если вопрос покажется глупым. Я пытаюсь использовать CompletableFuture для создания неблокирующего вызова. У меня есть метод, который возвращает логическое значение public...
2752 просмотров

не существует экземпляра (ов) переменной (переменных) типа U, так что Foo соответствует CompletionStage‹U›
Я был в этом в течение нескольких часов, но, кажется, не могу распутать это. Ошибка относится к этому сегменту кода: (Полный код внизу этого вопроса. Я использую скриншоты, чтобы визуально показать проблему.) Сама ошибка:...
3675 просмотров
schedule 16.02.2023

Как объединить несколько ответов CompletionStage типа List (для меня) или какой-либо другой в java
Я пытаюсь создать несколько CompletionStage типа List, например. CompletionStage<List<Car>> . И в конце я хочу объединить все ответы типа <List<Car>> в один список в одном CompletionStage ....
4113 просмотров

Использование значений из ранее связанных лямбда-выражений thenCompose в Java 8
Стиль программирования Java 8, который предпочитают мои коллеги, заключается в последовательном соединении асинхронных вызовов, например, CompletionStage<E> someMethod() { return doSomething().thenCompose(a -> { // ......
1317 просмотров
schedule 03.10.2022