RI
Как правильно остановить Future, если произошел Await.result для нее?
Future нельзя стопнуть. await.result блокируется и ждет выполнения Future
Size: a a a
2020 September 09
А
Future нельзя стопнуть. await.result блокируется и ждет выполнения Future
что тогда замен Future правильно использовать, если хочется полностью останавливать параллельный поток по таймауту?
RI
что тогда замен Future правильно использовать, если хочется полностью останавливать параллельный поток по таймауту?
Если ты блокируешь поток, то await.result тебе вернет значение из Future. Обычно, люди используют Future чтобы не блокироваться.
GP
что тогда замен Future правильно использовать, если хочется полностью останавливать параллельный поток по таймауту?
cats-effects или monix
А
Если ты блокируешь поток, то await.result тебе вернет значение из Future. Обычно, люди используют Future чтобы не блокироваться.
Я таким образом пытаюсь отловить зависание запроса к удаленной бд.
Я точно знаю, что если запрос выполняется дольше условных 100 секунд, то результата не будет никогда и хотелось бы прервать Future и запустить заново
Я точно знаю, что если запрос выполняется дольше условных 100 секунд, то результата не будет никогда и хотелось бы прервать Future и запустить заново
val f = Future { /* чтение по jdbc удаленной бд*/ }
Await.result(f, 100.seconds)GP
там и таймауты есть, и кэнселебл
А
там и таймауты есть, и кэнселебл
спасибо, почитаю. Пока тогда оставлю без ретраев..
GP
спасибо, почитаю. Пока тогда оставлю без ретраев..
если тебе ретрай с бэкоффом нужен то он и на фучах может быть
А
если тебе ретрай с бэкоффом нужен то он и на фучах может быть
это как? или по каким ключевым словам гуглить?
DZ
cats-effects или monix
zio сразу, там же как раз KPACUBO сделали
GP
это как? или по каким ключевым словам гуглить?
так и гугли scala future exponential backoff
GP
и через таймер есть наверн и рекурсивно через слипы
GP
zio сразу, там же как раз KPACUBO сделали
во или зио!
GP
zio сразу, там же как раз KPACUBO сделали
композируемо и с приятным апи?
DZ
канселеблы, ретраи вот это вот всё
А
спасибо, посмотрю тогда zio, вместо cats-effects
А
я тут подумал, наверно, еще можно установить spark.network.timeout, если у меня чтение через spark.read.jdbc ?
А
Ламерский вопрос: а если начинать изучения фреймворков scala, то что более распространено и перспективно: zio или cats? Или у них разные предназначения?
DZ
разные