Вопросы по теме '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 просмотров
schedule
26.03.2023
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 просмотров
schedule
12.03.2023
Пользовательские исполнители PlayFramework при использовании CompletableFutures и java
В последних версиях PlayFramework они начали использовать CompletionStage в качестве типа возвращаемого значения для контроллеров, которые будут использоваться для асинхронного выполнения, или, в двух словах, если вы возвращаете CompletionStage ,...
758 просмотров
schedule
24.07.2022
Как мне продолжить CompletableFuture, не дожидаясь вывода
У меня возникла ситуация, когда мне нужно реализовать рекурсию с CompletableFuture . Я хочу вызывать recursionFuture(ex) всякий раз, когда любой из CompletableFuture возвращает какой-либо результат, но я не уверен, как это реализовать. В...
1449 просмотров
schedule
13.10.2022
Java Future — Spring Authentication не имеет значения для AuditorAware
Это мой сценарий:
В моем приложении включен аудит Mongo с пользовательским AuditorAware, который получает текущего пользователя из файла SecurityContext . Это хорошо работает с синхронными методами, и текущий аудитор успешно сохраняется, но я не...
3817 просмотров
schedule
30.06.2022
Должен ли API возвращать CompletionStage или CompletableFuture
При создании API рекомендуется кодировать интерфейс, поэтому кажется, что возврат CompletionStage кажется лучшим подходом. Однако я понял, что всегда вызываю .toCompletableFuture после получения CompletionStage. Каков рекомендуемый подход в этом...
1581 просмотров
schedule
08.08.2023
Как я могу перехватить исключение RejectedExecutionException, созданное при вызове комплететаблефутуре комплетеасинк?
В следующем примере кода я ввожу biconsumer , который спит в течение 100 миллисекунд, как действие завершения набора завершаемого будущего. Я использовал метод whenCompleteAsync , предоставив для использования отдельный executorService ....
1885 просмотров
schedule
22.02.2022
Завершаемые фьючерсы 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 просмотров
schedule
26.10.2022
Наращивание памяти при использовании 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 просмотров
schedule
27.10.2022
CompletableFuture — укажите метод, который возвращает логическое значение для вызова SupplyAsync.
Я возвращаюсь к Java после долгого времени, поэтому прошу прощения, если вопрос покажется глупым. Я пытаюсь использовать CompletableFuture для создания неблокирующего вызова. У меня есть метод, который возвращает логическое значение
public...
2752 просмотров
schedule
12.03.2023
не существует экземпляра (ов) переменной (переменных) типа U, так что Foo соответствует CompletionStage‹U›
Я был в этом в течение нескольких часов, но, кажется, не могу распутать это. Ошибка относится к этому сегменту кода:
(Полный код внизу этого вопроса. Я использую скриншоты, чтобы визуально показать проблему.)
Сама ошибка:...
3675 просмотров
schedule
16.02.2023
Как объединить несколько ответов CompletionStage типа List (для меня) или какой-либо другой в java
Я пытаюсь создать несколько CompletionStage типа List, например. CompletionStage<List<Car>> . И в конце я хочу объединить все ответы типа <List<Car>> в один список в одном CompletionStage ....
4113 просмотров
schedule
25.06.2023
Использование значений из ранее связанных лямбда-выражений thenCompose в Java 8
Стиль программирования Java 8, который предпочитают мои коллеги, заключается в последовательном соединении асинхронных вызовов, например,
CompletionStage<E> someMethod() {
return doSomething().thenCompose(a -> {
// ......
1317 просмотров
schedule
03.10.2022