VP
Оно не дружит с корутинами ровно никак
@Synchronized зачем?Size: a a a
2020 December 17
I
Так, а
не нужен абсолютно, осталось от заготовки в плейграунде
I
Не верю 🙂
да, совешенно верно, вызывается асинхронно, но handler не ловит эксепшн
VP
да, совешенно верно, вызывается асинхронно, но handler не ловит эксепшн
Может, потому что программа завершается до его возникновения?
I
Может, потому что программа завершается до его возникновения?
не
I
I
Сихронно launch отрабатывает если контекст брать из coroutineContext
val scope = CoroutineScope(coroutineContext)
scope.launch{} - и вот этот код срабатывает синхронно внутри suspend функции
val scope = CoroutineScope(coroutineContext)
scope.launch{} - и вот этот код срабатывает синхронно внутри suspend функции
I
просто sendbox не умеет coroutineContext
I
так, стоп, в песочнице все работает… сорян, пойду попью чай
VP
Сихронно launch отрабатывает если контекст брать из coroutineContext
val scope = CoroutineScope(coroutineContext)
scope.launch{} - и вот этот код срабатывает синхронно внутри suspend функции
val scope = CoroutineScope(coroutineContext)
scope.launch{} - и вот этот код срабатывает синхронно внутри suspend функции
А, так вы handler указали не у scope, а у конкретного launch, вот оно на второй и не влияет
VP
Вы хотите чтобы он всё равно тот же использовался?
I
val handler = CoroutineExceptionHandler { _, exception ->
println("CoroutineExceptionHandler got $exception")
}
val scope = CoroutineScope(SupervisorJob())
suspend fun criticalSectionSuspending() {
println("Starting!")
val scope2 = CoroutineScope(coroutineContext)
val someJob = scope2.launch {
delay(200)
println("Delay!")
throw Exception("Delay Exception")
}
println("Ending!")
}
fun main() {
scope.launch(handler) {criticalSectionSuspending()}
Thread.sleep(500)
}I
вот так работает все, и handler тоже
VP
val handler = CoroutineExceptionHandler { _, exception ->
println("CoroutineExceptionHandler got $exception")
}
val scope = CoroutineScope(SupervisorJob())
suspend fun criticalSectionSuspending() {
println("Starting!")
val scope2 = CoroutineScope(coroutineContext)
val someJob = scope2.launch {
delay(200)
println("Delay!")
throw Exception("Delay Exception")
}
println("Ending!")
}
fun main() {
scope.launch(handler) {criticalSectionSuspending()}
Thread.sleep(500)
}Да, так будет работать, но такой код ломает structured concurrency (если вас это вообще волнует)
I
Почему ломает?
VP
Почему ломает?
Как минимум потому что
1. После завершения работы suspend функции что-то запущенное из неё продолжает работать
2. Это что-то может кидать исключения мимо
1. После завершения работы suspend функции что-то запущенное из неё продолжает работать
2. Это что-то может кидать исключения мимо
try { }
В общем, очень плохой подход, не надо так. Поддерживаемость такого кода будет на дне.I
1. согласен, тут надо ручками менеджить
2. как? я ж как раз и заморачиваюсь, чтобы все что произошло внутри этой суспенд функции с ошибкой, прилетело в самый самый верхний эксепшнХендлер
2. как? я ж как раз и заморачиваюсь, чтобы все что произошло внутри этой суспенд функции с ошибкой, прилетело в самый самый верхний эксепшнХендлер
VP
В вашем случае можно сделать так:
suspend fun criticalSectionSuspending() = coroutineScope {
println("Starting!")
val someJob = launch {
delay(200)
println("Delay!")
throw Exception("Delay Exception")
}
println("Ending!")
}VP
1. согласен, тут надо ручками менеджить
2. как? я ж как раз и заморачиваюсь, чтобы все что произошло внутри этой суспенд функции с ошибкой, прилетело в самый самый верхний эксепшнХендлер
2. как? я ж как раз и заморачиваюсь, чтобы все что произошло внутри этой суспенд функции с ошибкой, прилетело в самый самый верхний эксепшнХендлер
А с чего оно должно прилетать в верхний ExceptionHandler, если например вызов этой функции обёрнут в
Вы бы объяснили свою задачу подробнее, пока вообще не понятно, зачем писать такой код.
try { }?Вы бы объяснили свою задачу подробнее, пока вообще не понятно, зачем писать такой код.
I
так нет оберток в try