Шпаргалка: Kotlin Coroutines Channels и Actor-модель

Значимый прорыв формирует отрасль ИИ: bm9 4 минуты назад Шпаргалка: Kotlin Coroutines Channels и Actor-модель Средний 7 мин 9 Android * Kotlin * Мнение Тема 1. Как выглядит Kotlin Coroutine без макияжа Тема 2. Kotlin suspend функции Тема 3.

Kotlin Coroutine диспетчеры и потоки: где выполняются корутины? Structured Concurrency и отмена корутин Тема 5. Обработка исключений в Kotlin CoroutinesПытаюсь лучше понять работу Kotlin Coroutines.

Технические детали

Беру небольшую тему про Kotlin Coroutines и пытаюсь разобраться и написать шпаргалку (максимально кратко и лаконично). Сегодня поговорим про Каналы (Channel) и паттерн Actor. В предыдущих частях я писал, что обычные suspend-функции возвращают результат только один раз.

Но что делать, если у нас есть непрерывный поток данных, который асинхронно генерируется в одной корутине, а обрабатываться должен в другой (или даже в нескольких)? Нам нужна потокобезопасная «труба». В мире корутин этой трубой является Channel.

Что такое Channel под капотом? Концептуально Channel — это потокобезопасная очередь (Queue), адаптированная специально для корутин. Главное отличие канала от классических блокирующих очередей заключается в том, что его методы не блокируют потоки операционной системы.

Отраслевые последствия

Вместо этого они используют механизм приостановки. Как мы помним, suspend-функции позволяют приостанавливать выполнение кода без блокировки потока. Интерфейс канала логически разделен на две части для соблюдения инкапсуляции:SendChannel — интерфейс для отправителя (имеет suspend-функцию send()).

ReceiveChannel — интерфейс для получателя (имеет suspend-функцию receive()). Когда корутина-отправитель вызывает send(), а получатель еще не готов (например, буфер заполнен), отправитель просто приостанавливается (suspend), освобождая текущий поток для других задач. Состояние корутины сохраняется в Continuation, пока получатель не заберет данные.

То же самое работает и в обратную сторону для receive(). Виды каналов (Capacity)При создании канала мы можем управлять размером его внутреннего буфера: Channel(capacity). От этого параметра кардинально меняется поведение системы:Rendezvous (по умолчанию, capacity = 0): Буфера нет вообще.

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