Вопросы по теме 'completable-future'
Как выбрать исполнителя для CompletableFuture::supplyAsync
CompletableFuture::supplyAsync(() -> IO bound queries)
Как выбрать Executor для CompletableFuture::supplyAsync, чтобы не загрязнять ForkJoinPool.commonPool() .
В Executors есть много вариантов ( newCachedThreadPool , newWorkStealingPool...
6308 просмотров
schedule
18.02.2022
ForkJoinTask против CompletableFuture
В Java 8 есть два способа запуска асинхронных вычислений — CompletableFuture и ForkJoinTask . Они оба кажутся довольно похожими — внутренние классы CompletableFuture даже расширяют ForkJoinTask .
Есть ли причина использовать один над другим?...
5098 просмотров
schedule
02.09.2022
Почему метод thenAccept() CompletableFuture не работает в основном потоке
Я обрабатываю длительную операцию внутри SupplyAsync() CompletableFuture и получаю результат в thenAccept(). Иногда thenAccept() выполняется в основном потоке, но некоторое время он работает в рабочем потоке. Но я хочу запустить операцию thenAccept()...
3930 просмотров
schedule
13.06.2022
Параллельные вызовы базы данных с использованием потоков Java 8 и CompletableFuture
Я хотел бы воспроизвести и распараллелить следующее поведение с потоками Java 8:
for (animal : animalList) {
// find all other animals with the same breed
Collection<Animal> queryResult = queryDatabase(animal.getBreed());...
6859 просмотров
schedule
08.04.2024
Поддерживает ли Vertx 3 CompletableFuture?
Я хочу разработать свой стиль обещания приложения, используя vertx, и CompletableFuture действительно подходит для этой цели, но JVM использует fork/join в фоновом режиме для CompletableFuture, и это может нарушить безопасность Vertx Thread.
У вас...
3601 просмотров
schedule
06.11.2023
Отслеживание состояния нескольких асинхронных запросов при использовании Spring @Async
Я использую весеннюю загрузку для разработки сервисов в своем приложении.
У меня есть сценарий, в котором запрос, отправленный на серверную часть, займет некоторое время.
Чтобы не ждать клиента, я хочу немедленно вернуть ответ с сообщением, что...
1060 просмотров
schedule
26.10.2023
Как назначить задачу CompletableFuture, чтобы после ее выбора ее не нужно было поднимать снова
У меня есть несколько таких задач:
public static String task1()
public static String task2()
public static String task3()
public static String task4()
public static String task5()...
240 просмотров
schedule
17.08.2022
CompletableFutures и фильтрация на основе значений, которые находятся внутри
Я сейчас немного запутался, поэтому у меня есть метод, который должен возвращать CompletableFuture<List<A>>
внутри метода:
CompletableFuture<List<String>> toReturn = asyncCall().thenApply(....)
.thenCompose(listOfStuff...
3357 просмотров
schedule
21.10.2022
Как обрабатывать объединение нескольких асинхронных CompletableFuture?
Я читал, что CompletableFuture может объединять несколько фьючерсов с runAfterBoth , но что, если я хочу объединить более двух?
CompletableFuture<Boolean> a = new CompletableFuture<>();
CompletableFuture<Boolean> b = new...
4451 просмотров
schedule
06.05.2023
Как объединить асинхронный CompletableFuture с завершенным CompletableFuture?
Я изучил следующий код: Как объединить 3 или более CompletionStages? , но в этом посте объединены только Завершенные задачи из CompletableFutures.
Как я могу объединить асинхронный CompletableFuture с Completed CompletableFuture, чтобы объединить...
459 просмотров
schedule
05.08.2023
Вложенные фьючерсы не выполняются
Я столкнулся со странной ситуацией. Я возился с CompletableFuture , и при запуске следующего кода у меня были неожиданные результаты:
public static void main(String[] args) {...
1236 просмотров
schedule
12.04.2023
Использование функций Anonymous Versus Member
Я работал с CompletableFutures , когда столкнулся с ситуацией. Допустим, я хотел сделать некоторую очистку после завершения асинхронной операции. Есть ли важная разница между вызовом функции-члена таким образом? Почему я предпочел бы первый пример...
41 просмотров
schedule
03.11.2022
Исполнитель ForkJoinPool по умолчанию занимает много времени
Я работаю с CompletableFuture для асинхронного выполнения потока, созданного из источника списка.
поэтому я тестирую перегруженный метод, то есть SupplyAsync CompletableFuture, в котором один метод принимает только один параметр поставщика, а другой...
12185 просмотров
schedule
10.10.2023
Что по умолчанию для этого Collectors.toList ожидает список объектов?
Мы работаем над асинхронизацией некоторых вызовов с использованием аннотации @Async и CompletableFutures в Java. У нас есть несколько Pojo, для которых мы создаем объекты в нашем асинхронном вызове, но при попытке собрать результаты в список Eclipse...
214 просмотров
schedule
01.03.2022
Как использовать CompletableFuture в java 8, чтобы запустить асинхронную задачу и позволить основному потоку завершиться и выйти
У меня есть следующий код (более или менее):
ExecutorService executor = Executors.newFixedThreadPool(10);
CompletableFuture
.supplyAsync(()->{
return longRunningMethodThatReturnsBoolean();
}, executor)...
2312 просмотров
schedule
20.09.2023
Как создать собственное исключение из CompletableFuture?
Вопрос: как я могу напрямую выбросить настраиваемое исключение из .exceptionally() ?
List<CompletableFuture<Object>> futures =
tasks.stream()
.map(task -> CompletableFuture.supplyAsync(() -> businessLogic(task))...
6104 просмотров
schedule
01.04.2022
Правильно ли преобразовывать CompletableFuture ‹Stream ‹T›› в Publisher ‹T›?
Чтобы разрешить несколько итераций в результирующем потоке из CompletableFuture<Stream<String>> , я рассматриваю один из следующих подходов:
Преобразуйте полученное будущее в CompletableFuture<List<String>> через:...
5736 просмотров
schedule
08.01.2024
Java-эквивалент JavaScript Promise.reject
Название говорит само за себя, но что такое эквивалент Java 8 для JavaScript Promise.reject ? Я ищу статический метод для CompletableFuture это создаст Future в исключительном состоянии, но я его не вижу.
207 просмотров
schedule
31.10.2023
Какой исполнитель использует CompletableFuture.allOf?
Предположим, у нас есть два исполнителя, 1 и 2.
Мы можем настроить, какой исполнитель использовать при выполнении
CompletableFuture<Integer> cf1 = CompletableFuture.supplyAsync(()-> {return 1;}, executor1) //executor1...
3480 просмотров
schedule
18.01.2023
Как использовать CompletableFuture, не рискуя ошибкой StackOverflowError?
Я хочу пройтись по пространству поиска асинхронной функции. Я закодировал логику следующим образом:
/**
* Assuming that a function maps a range of inputs to the same output value, minimizes the input value while
* maintaining the output value....
1220 просмотров
schedule
05.02.2024
