Control.Concurrent.Chan

Авторское право	(c) The University of Glasgow 2001
Лицензия	В стиле BSD (см. файл libraries/base/LICENSE)
Сопровождающий	libraries@haskell.org
Стабильность	стабильный
Переносимость	непереносимый (параллелизм)
Безопасный Haskell	Trustworthy
Язык	Haskell2010

Тип Chan

data Chan a Source

Chan — это абстрактный тип, представляющий канал FIFO неограниченной длины.

Операции

newChan :: IO (Chan a) Source

Создаёт и возвращает новый экземпляр Chan.

writeChan :: Chan a -> a -> IO () Source

Записывает значение в Chan.

readChan :: Chan a -> IO a Source

Считывает следующее значение из Chan. Блокируется, если канал пуст. Поскольку конец канала для чтения является MVar, эта операция наследует гарантии справедливости MVar (например, потоки, заблокированные в этой операции, пробуждаются в порядке FIFO).

Вызывает BlockedIndefinitelyOnMVar, если канал пуст и ни один другой поток не хранит ссылку на канал.

dupChan :: Chan a -> IO (Chan a) Source

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

(Обратите внимание, что дублированный канал не равен исходному. Поэтому: fmap (c /=) $ dupChan c возвращает True для всех c.)

Интерфейс потоков

getChanContents :: Chan a -> IO [a] Source

Возвращает ленивый список, представляющий содержимое указанного Chan, подобно hGetContents.

writeList2Chan :: Chan a -> [a] -> IO () Source

Записывает целый список элементов в Chan.