Краткий ответ

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

В синхронном канале это обычно различается как блокировка или состояние Empty против ошибки отключения. В асинхронном канале ожидание представляется как Pending, а после закрытия получение завершается специальным признаком конца, например None.

Исторический контекст

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

Поэтому закрытие канала связано с владением его отправляющими концами. Такое решение позволяет не вводить отдельный флаг завершения, который пришлось бы защищать синхронизацией и согласовывать с отправкой сообщений.

Постановка проблемы

Пустая очередь не означает завершение производства. Отправитель мог временно задержаться, а асинхронная задача может ещё не быть готова отправить следующее сообщение.

Если получатель ошибочно трактует отсутствие сообщения как конец работы, он завершится преждевременно и может потерять последующие данные. Если же он бесконечно ждёт после закрытия канала, система зависнет или завершит рабочий цикл только по тайм-ауту.

Подробное решение

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

Важно учитывать порядок: если последний отправитель уничтожен, но в очереди ещё есть сообщения, получатель сначала должен получить эти сообщения. Сигнал закрытия появляется только после исчерпания очереди.

Для синхронного std::sync::mpsc вызов recv ждёт сообщение, пока канал не отключён; после отключения он возвращает ошибку. Неблокирующая проверка различает временную пустоту и отключение: Empty означает «попробовать позже», а Disconnected — «новых сообщений не будет».

В асинхронных каналах ожидание отсутствующего сообщения не блокирует поток исполнителя: future возвращает Pending, а runtime продолжает другие задачи. После закрытия и опустошения канала операция получения обычно возвращает значение, обозначающее завершение потока сообщений, например None.

Один из минимальных вариантов для синхронного канала:

use std::sync::mpsc;

fn main() {
    let (tx, rx) = mpsc::channel();
    tx.send(1).unwrap();
    drop(tx);

    assert_eq!(rx.recv().unwrap(), 1);
    assert!(rx.recv().is_err());
}

После drop(tx) первое получение всё ещё возвращает уже отправленное сообщение. Следующее получение сообщает об отключении, потому что отправляющих концов больше нет.

Компромисс такого подхода — завершение зависит от корректного управления всеми копиями отправителя. Если лишняя копия хранится в структуре, замыкании или задаче runtime, получатель продолжит ждать, хотя логически производство уже завершено.

Ситуация из практики

Сервис запускает несколько рабочих задач, каждая получает копию отправителя и передаёт результаты одному агрегатору. Агрегатор обрабатывает сообщения в цикле и должен завершить запись итогового отчёта только после окончания всех workers.

Рассматривались два варианта. Первый — послать специальное сообщение Завершено от каждой задачи: это явно, но требует учитывать сбои, дублирование сигналов и согласование числа workers. Второй — положиться на закрытие канала: workers уничтожают свои отправители после завершения, а агрегатор заканчивает цикл после сигнала отключения.

Выбран второй вариант, потому что завершение следует из владения ресурсом и не смешивается с обычными данными. При этом главный поток заранее уничтожает свою исходную копию отправителя; иначе канал останется открытым даже после завершения workers. В результате агрегатор обрабатывает все уже отправленные результаты и затем корректно завершает работу без тайм-аутов.

Что кандидаты часто упускают

Может ли получатель считать пустую очередь признаком закрытия канала?

Нет. Пустая очередь означает только отсутствие доступных сообщений в данный момент. В синхронном канале получение может заблокироваться, а в асинхронном — вернуть Pending; оба состояния совместимы с тем, что отправитель ещё существует и позже передаст данные.

Что произойдёт, если последний отправитель уничтожен, пока в канале ещё есть сообщения?

Получатель не должен сразу потерять эти сообщения. Закрытие запрещает появление новых сообщений, но уже помещённые в очередь данные остаются доступными. Сигнал окончательного завершения наблюдается после их чтения.

Почему канал иногда не закрывается после завершения всех видимых producers?

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