KS
Ну в смысле когда ишью деду накатаю тогда запаблишу
Size: a a a
2020 July 02
λ
ты сперва запаблиши
λ
может не в деде дело
Oℕ
Kirill Shelopugin
Там в канселейшене дело, походу - он в race ждёт пока не заканселится основной файбер, а тот сидит ждёт пока блокирующий вызов не закончится
интересно
Oℕ
а какая логика канселейшона
Oℕ
блокирующий канселейшон - это велико
Oℕ
типа какой-то роллбек?
λ
а можно было сделать socket.close и откатилось бы само)
w
а можно было сделать socket.close и откатилось бы само)
KS
Ну там вот так в эффектах
Проверили - если имплементировать через racePair самим, но до канцеляции залогировать - всё так и работает - таймер просыпается через таймаут, логирует, потом пытается закенселить файбер. Т.к. файбер сидит пыхтит в блокирующем JDBC API, канселлейшен тоже ждет пока тот допыхтит до таймаута DB пула и последующие вычисления честно отменяются
def race[A, B](fa: F[A], fb: F[B]): F[Either[A, B]] =
flatMap(racePair(fa, fb)) {
case Left((a, fiberB)) => map(fiberB.cancel)(_ => Left(a))
case Right((fiberA, b)) => map(fiberA.cancel)(_ => Right(b))
}
Проверили - если имплементировать через racePair самим, но до канцеляции залогировать - всё так и работает - таймер просыпается через таймаут, логирует, потом пытается закенселить файбер. Т.к. файбер сидит пыхтит в блокирующем JDBC API, канселлейшен тоже ждет пока тот допыхтит до таймаута DB пула и последующие вычисления честно отменяются
w
Kirill Shelopugin
Ну там вот так в эффектах
Проверили - если имплементировать через racePair самим, но до канцеляции залогировать - всё так и работает - таймер просыпается через таймаут, логирует, потом пытается закенселить файбер. Т.к. файбер сидит пыхтит в блокирующем JDBC API, канселлейшен тоже ждет пока тот допыхтит до таймаута DB пула и последующие вычисления честно отменяются
def race[A, B](fa: F[A], fb: F[B]): F[Either[A, B]] =
flatMap(racePair(fa, fb)) {
case Left((a, fiberB)) => map(fiberB.cancel)(_ => Left(a))
case Right((fiberA, b)) => map(fiberA.cancel)(_ => Right(b))
}
Проверили - если имплементировать через racePair самим, но до канцеляции залогировать - всё так и работает - таймер просыпается через таймаут, логирует, потом пытается закенселить файбер. Т.к. файбер сидит пыхтит в блокирующем JDBC API, канселлейшен тоже ждет пока тот допыхтит до таймаута DB пула и последующие вычисления честно отменяются
это нихуя не читаемо
Oℕ
а таймаут через рейс сделан:
KS
Проверить очень просто - в запросе делает задержка 10 секунд, таймаут 5. Ну и логируется. Оно честно работает 10 секунд, потом вываливает TimeoutException со словами "прошло 5 секунд"
KS
а таймаут через рейс сделан:
Да
w
Oℕ
в мониксе тоже виснет?
KS
w
Kirill Shelopugin
ущерб читаемости, и не в ботлнеке (сам таким иногда страдаю)
KS
в мониксе тоже виснет?
Да