Привет, CompletableFuture с orTimeout, как понять какая именно CompletableFuture отвалилась? Может

Я с этим не работал, но разве CompletableFuture не умеет эксепшены наружу выбрасывать (exceptionally(), handle()). Передать id таски в мессадже эксепшена не получится?

0

21.06.2022

Iglï Bluetōthsün Автор вопроса

Александр Евтеев
Я с этим не работал, но разве CompletableFuture не...

Вот именно с этим и проблема, нету никакого контекста, либо у меня руки кривые(что тоже вариант) Но пока решения не нашел

0

21.06.2022

Александр Евтеев

Iglï Bluetōthsün
Вот именно с этим и проблема, нету никакого контек...

Расскажи подробнее про «нет контекста»: ведь если ты хочешь знать, какая задача завалилась - значит, задачи чем-то отличаются? Хотя бы входными параметрами. Их и логировать. Или ты о другом контексте?

0

21.06.2022

Iglï Bluetōthsün Автор вопроса

Грубый пример После вызова нескольких CompletableFuture for( i .. 10) { val suplier = Suplier { print(I) } CompletableFuture.supplyAsync(supplier, executor).orTimeout(TIMEOUT, TimeUnit.SECONDS) } Как понять какой из них свалился по таймауту?

0

21.06.2022

Александр Евтеев

Iglï Bluetōthsün
Грубый пример После вызова нескольких CompletableF...

Примерно так получается на твоем примере: https://gist.github.com/evteev777/8a7ec6ad7efcdd13cc40866dd62206e7 Вывод с рандомными таймаутами: result=0 result=1 ERROR: java.lang.RuntimeException: i=2, cause: java.util.concurrent.TimeoutException ERROR: java.lang.RuntimeException: i=3, cause: java.lang.IllegalArgumentException: Exception message: i=3 result=4 итд Просто из CompletableFuture может вернуться или result, или exception. Но в случае с TimeoutException эксепшен не пробрасывается из задачи, а кидается позже, в самой CompletableFuture. Поэтому остается логировать только входные параметры, а не контекст в процессе выполнения задачи Это в первом приближении, наверняка можно красивее сделать )

0

21.06.2022

Iglï Bluetōthsün Автор вопроса

Александр Евтеев
Примерно так получается на твоем примере: https://...

“Но в случае с TimeoutException эксепшен не пробрасывается из задачи” да именно это и проблема Ваше решение как раз и дает контекст потому что finalI виден и всех методов вызывающихся с CompletableFuture Моя проблема была в вызове цепочки настройки CompletableFuture без доступа к глобальной переменной, решил тасканием объекта контекста рядом с future, не идеально но работает

0

21.06.2022

Александр Евтеев

Iglï Bluetōthsün
“Но в случае с TimeoutException эксепшен не пробра...

Почему неидеально? А как по другому, если не таскать везде объект контекста, который больше ниоткуда недоступен?

0

22.06.2022

Anton Arhipov · Accepted Answer

Anton Arhipov

у supplyAsync есть второй параметр, туда можно подложить executor. можно заврапить настоящий executor в котором предполагается запускать операции и делегировать запуск тасков из враппера в ностоящий executor при этом логируя, какой таск запускается

0

21.06.2022

170 похожих чатов

Привет, CompletableFuture с orTimeout, как понять какая именно CompletableFuture отвалилась? Может

12 ответов

Похожие вопросы