Открыть главное меню

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

Каналы являются основополагающими для подхода исчисления процессов, и появились в взаимодействующих последовательных процессах (CSP), формальной модели параллелизма. Каналы используются во многих производных языках программирования, таких как Occam, Limbo (через языки Newsqueak и Алеф). Они также используются в потоковой библиотеке libthread языка программирования Си в ОС Plan 9, а также в Stackless Python и языке Go.

Реализации каналовПравить

Каналы, созданные по аналогии с моделью CSP, являются синхронными: процесс, ожидающий получения объекта из канала блокируется, пока объект не будет отправлен. Такие реализации называют «rendezvous». Типичные операции над такими каналами представлены на примере интерфейсов каналов библиотеки libthread:

  • Создание канала фиксированного или переменного размера, функция возвращает ссылку или handle
    Channel* chancreate(int elemsize, int bufsize)
    
  • Отправка в канал
    int chansend(Channel *c, void *v)
    
  • Получение из канала
    int chanrecv(Channel *c, void *v)
    

Каналы libthreadПравить

Потоковая библиотека libthread, изначально созданная для ОС Plan 9, предлагает возможности межпоточного взаимодействия через каналы фиксированного размера.

События OCamlПравить

Модуль event языка OCaml реализует типизированные каналы для синхронизации. Когда вызываются функции send и receive модуля, они создают соответствующие события, которые могут быть синхронизированы.

ПримерыПравить

XMOS XCПравить

В XMOS язык XC предоставляет встроенный тип «chan» и два оператора «<:» и «:>» для отправки и приема данных из канала.[1]

В примере производится запуск двух аппаратных потоков в XMOS, исполняющих две строки из блока «par». Первая строка передает число 42 через канал. Вторая строка ожидает приема значения из канала и записывает полученное значение в переменную x. Язык XC также поддерживает асинхронный прием из каналов с помощью оператора select.

chan c;
int x;
par {
  c <: 42;
  c :> x;
}

Язык GoПравить

Этот фрагмент кода Go сначала создает канал c, затем порождает goroutine, которая посылает 42 через канал. Когда число отправлено в канал, переменная x получит значение 42. Go позволяет каналам буферизировать содержимое. Возможна неблокирующая операция получения из канала с помощью блока select.[2]

c := make(chan int)

go func() {c <- 42}()

x := <- c

ПримененияПравить

В дополнение к использованию для межпоточного взаимодействия, каналы могут использоваться как примитив для реализации иных конкурентных конструкций. Например, каналы позволяют реализовать futures and promises, где future является одноэлементным каналом, а promise — процесс, который отправляет в канал, исполняя future.[3] Сходным образом можно реализовать iterators через каналы.[4]

ПримечанияПравить

  1. XMOS Programming Guide (недоступная ссылка). Дата обращения 4 августа 2016. Архивировано 4 марта 2016 года.
  2. Effective Go - The Go Programming Language
  3. «Futures», Go Language Patterns
  4. «Iterators», Go Language Patterns

СсылкиПравить