Телеграмм чат группы kotlin

Size: a a a

Kotlin Community

2020 March 10

вывод после выполнения:
Start
Job cancel

// после завершения буф-и
End
Сatch CancellationException

а хотелось:
Start
Job cancel
Сatch CancellationException

источник

16:03пожаловаться #1

Alexey Tkachenko in Kotlin Community

А в каких потоках тут что запускается и какие из них останавливаются при Thread.sleep()?

источник

16:08пожаловаться #2

Vladimir Petrakovich in Kotlin Community

Alexey Tkachenko

Люди, я что-то пропустил и корутины при отмене научились прерывать операции чтения из файлов?

Они умеют выполнять что-то при запросе отмены. А что при этом можно сделать для прерывания операции - это уже другой вопрос.

источник

16:09пожаловаться #3

Alexey Tkachenko in Kotlin Community

Vladimir Petrakovich

Да, некорректно спросил. В общем, всё будет сильно зависеть от того, что в каком потоке запустится

источник

16:10пожаловаться #4

Vladimir Petrakovich in Kotlin Community

Alexey Tkachenko

Да, некорректно спросил. В общем, всё будет сильно зависеть от того, что в каком потоке запустится

Да без разницы, какой поток. Ну разумеется не из того, который заблокирован.

источник

16:11пожаловаться #5

Alexey Tkachenko in Kotlin Community

Логично. И раз у нас чтение запущено в Dispatchers.IO, скорее всего, оно в фоновом потоке, верно? Тогда cancel должен в основном потоке отработать сразу?

источник

16:13пожаловаться #6

Vladimir Petrakovich in Kotlin Community

Alexey Tkachenko

Да, скорее всего оно запущено в потоке, который можно блокировать, а желание отменить возникнет в каком-то другом (может и из Dispachers.IO тоже), в котором и будет вызван cancel()

источник

16:15пожаловаться #7

Alexey Tkachenko in Kotlin Community

Понятно. Ну, а как там реализована диспетчеризация исключений между потоками, я даже гадать не буду

источник

16:17пожаловаться #8

Bogdan Panchenko in Kotlin Community

Boris Vanin

Это немного нелогично, потому что сумма интов как бы на выходе лонг всё равно должна давать

Не всегда) но да

источник

17:38пожаловаться #9

Bogdan Panchenko in Kotlin Community

Михаил

инлайн классы не могут наследоваться если правильно помню

Только интерфейс

источник

17:39пожаловаться #10

Bogdan Panchenko in Kotlin Community

Ivan Sablin

для этого и делал

Нужно понимать что в этом случае - боксинг, если инлайн классы не работают явно - вам не нужен инлайн класс

источник

17:41пожаловаться #11

Bogdan Panchenko in Kotlin Community

Ivan Sablin

Компилятор подсвечивает инлайн, что он там кричит

источник

17:42пожаловаться #12

Bogdan Panchenko in Kotlin Community

Alidibir Akhbulatov

вот пример кода: https://codeshare.io/aY1Kyn

Отменой не решит если у вас блочится поток

источник

17:46пожаловаться #13

Bogdan Panchenko in Kotlin Community

Тут уже нужно смотреть на блокирующий код и смотреть как туда впихнуть delay(1)

источник

17:47пожаловаться #14

Oleg Yukhnevich in Kotlin Community

Bogdan Panchenko

Тут уже нужно смотреть на блокирующий код и смотреть как туда впихнуть delay(1)

delay(1) то зачем?

источник

17:51пожаловаться #15

Bogdan Panchenko in Kotlin Community

Oleg Yukhnevich

delay(1) то зачем?

Что бы была проверка на отмену

источник

17:51пожаловаться #16

Bogdan Panchenko in Kotlin Community

Без саспенд вызова проверки не будет

источник

17:52пожаловаться #17

Bogdan Panchenko in Kotlin Community

Oleg Yukhnevich

delay(1) то зачем?

Если его можно всунуть в блок. код*

источник

17:52пожаловаться #18

Alidibir Akhbulatov in Kotlin Community

Bogdan Panchenko

Тут уже нужно смотреть на блокирующий код и смотреть как туда впихнуть delay(1)

реальный код такой:

val sink = Okio.buffer(Okio.sink(file))
sink.use {
    it.writeAll(source) // здесь долгое выполнение
}

источник

17:53пожаловаться #19

Oleg Yukhnevich in Kotlin Community

https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/ensure-active.html
Есть вот такое

kotlin.github.io

ensureActive - kotlinx-coroutines-core

Library support for kotlin coroutines

источник

17:53пожаловаться #20