Канал (программирование)
Канал — модель межпроцессного взаимодействия и синхронизации через передачу сообщений в программировании. Сообщения могут быть посланы через канал, и другой процесс или поток, имеющий ссылку на канал, может получать поток сообщений, отправленных по каналу как поток. Различные реализации каналов могут быть синхронными или асинхронными, использовать буферизацию сообщений или нет.
Каналы являются основополагающими для подхода исчисления процессов и появились в взаимодействующих последовательных процессах (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]
Примечания[править | править код]
- ↑ XMOS Programming Guide. Дата обращения: 4 августа 2016. Архивировано из оригинала 4 марта 2016 года.
- ↑ Effective Go - The Go Programming Language. Дата обращения: 4 августа 2016. Архивировано 6 января 2015 года.
- ↑ «Futures Архивная копия от 4 декабря 2020 на Wayback Machine», Go Language Patterns Архивная копия от 11 ноября 2020 на Wayback Machine
- ↑ «Iterators Архивная копия от 15 октября 2020 на Wayback Machine», Go Language Patterns Архивная копия от 11 ноября 2020 на Wayback Machine
Ссылки[править | править код]
- Libthread Channel Implementation (англ.)
- Bell Labs and CSP Threads (англ.)
- Limbo — Inferno Application Programming (англ.)
- Stackless.com — Channels (англ.)
- Модуль Event в OCaml (англ.)