Kotlin Корутины — не могу разобраться?

Question

[RobCapa]

(Эту часть можно не читать)
{ Второй день пытаюсь хоть сколько-то продвинуться в изучении корутин, но в полном ступоре. Все материалы по ним просто отвратительные (по крайней мере, что я нашел на русском). Здесь только рассказывают об общей сути, а тут уже пример с конструкциями, которые никем не объяснены. Пробуешь запустить их у себя - так они еще и не работают. Никакой последовательности в материале, каждая статья - какая-то мешанина. Какие-то знания многопоточности в Java вообще не помогают. В общем, прошу прощение за лишние строки текста, наболело. }

Взял пример с этого сайта, но у меня он не работает:

import android.annotation.SuppressLint
import kotlinx.coroutines.*
class Test() {
    companion object {
        @SuppressLint("NewApi")
        @JvmStatic
        fun main(args: Array<String>) = runBlocking(CommonPool) {
            sendEmailSuspending()
            println("Email sent successfully.")
            println("Finished")
        }

        suspend fun sendEmailSuspending(): Boolean {
            val msg = async(CommonPool) {
                delay(500)
                "The message content"
            }
            val recipient = async(CommonPool) { getReceiverAddressFromDatabase() }
            println("Waiting for email data")

            return sendEmail(recipient.await(), msg.await())
        }
    }
}

async - подчеркнуто красным. В консоли получаю "Cannot access 'CommonPool': it is internal in 'kotlinx.coroutines'"

Вообще, у меня все эти функции async, launch и т.д. работают только внутри функции runBlocking {}, написать вне не могу, подчеркивает красным. Может, так и нужно, не знаю. Но в статьях, вроде как, в примерах их пишут и без runBlocking.

У меня были проблемы с доступом к пакету kotlinx, когда я первый раз пытался к нему обратиться. Конечно, в большинстве статей и книг, которые я просмотрел, ничего об этом и слова сказано не было. Поискав информацию как-то смог решить эту проблему, исправив build.gradle. Может, не до конца верно сделал и в этом проблема?

Наверное, я вообще под неправильным углом вижу корутины, но пока у меня не складывается цельной картины. Прошу вкратце объяснить, что тут не так. Можно хотя бы ссылку на толковый разбор всего этого

Comments

[Денис Загаевский]

А нету такого обзора. Технология большая и сложная, живи с этим)

Answer 1

[illuzor]

Взял пример с этого сайта, но у меня он не работает

Это очень старая статья. Api с тех пор изменилось

Вообще, у меня все эти функции async, launch и т.д. работают только внутри функции runBlocking {}, написать вне не могу,

Всё верно. Suspend функции можно вызывать только внутри suspend функций.

Главным источником знаний должна быть официальная документация. Там вполне понятно всё объясняется.

Comments

[RobCapa]

Могли бы вы сказать, для чего нужен runBlocking? В оф. документации в примере его использовали так

GlobalScope.launch {
        delay(1000L)
        println("World!")
}
println("Hello,") 
runBlocking {
        delay(2000L)
}

Но чаще в него заворачивают вообще весь код main. Что это дает на практике?

[illuzor]

RobCapa, мог бы, но лучше скину ссылку на документацию - https://kotlin.github.io/kotlinx.coroutines/kotlin...

[RobCapa]

illuzor, да, я читал это, но не понял.

Я экспериментировал с использованием:

fun main(args: Array<String>) = runBlocking {
    GlobalScope.launch {
        foo2()
    }
    foo()
}

В данном случае сначала выполнится foo, затем foo2. Без runBlocking функция foo2 не успеет выполниться. Я так понимаю, потому что GlobalScope.launch - это что-то вроде демона, который завершается вместе с основной программой.

Но почему с runBlocking foo2 все же завершается? И почему если в GlobalScope.launch я добавлю delay(), то программа завершается, не дождавшись foo2, хотя runBlocking на месте? Вот это меня и путает в понимании роли runBlocking. Как по мне, даже с delay() программа должна была дождаться завершения foo2. Хотя тут я, наверное, не понимаю принцип работы delay()

[RobCapa]

illuzor, продолжаю читать документацию и гуглить. Вроде, немного лучше понимаю. runBlocking не завершится, пока не завершатся все ее сопрограммы. Создание сопрограммы с помощью билдера GlobalScope.launch создает глобальную сопрограмму, которая не учитывается runBlocking. Для создания сопрограммы в конкретной области используем launch {}. Тогда runBlocking учитывает сопрограмму.

Я не думаю, что корректно описал процесс, но я пытаюсь пока понять хотя бы то, что вижу, а не внутренний механизм

[Денис Загаевский]

RobCapa, примерно так.
Не жди, что ты сейчас раскуришь по-быстрому что-то и поймёшь корутины. Эта ебанина адски сложная. Документация нифига не полная, и даже статьи создателей (например Елизарова) приходится перечитывать несколько раз, чтобы понять, что происходит. Разницу между скоупом и контекстом, я, например, до сих пор не понял. Просто ощущение, что им нужен был дополнительный уровень индирекции и поэтому они вывернули кишки наружу. Хз, что все в них так вцепились, имхо, технология тухлая.

[RobCapa]

Денис Загаевский, не могу оценить сложность технологии, так как только изучаю ее. Но с учебным материалом по ней явно проблемы. Что в книгах, что в статьях, что в видео-уроках - все начинается не с начала и с большими пропусками в объяснениях. Про треды в java было найти легко и материал доступно изложен, а тут фигня какая-то. После прочтения лишь больше вопросов возникает, что откуда взялось, зачем это нужно и т.д.

[Денис Загаевский]

RobCapa, могу только посочувствовать. Учитывай, что половина видео и статей вообще не имеет отношения к реальности, смотри на самые последние публикации.