Haskell. Erlang-style process communication.

[mibori]

Посмотрев на реализацию Erlang-style Distributed Haskell захотелось нарисовать что-то своё, простое, для коммуникации процессов внутри одного исходника. Получился достаточно небольшой модуль:

Comments

[rvp74]

> За эрланговскими конструкциями receive ... end и receive ... after ... end не гнался.

Кстати, да. У Эрланга логика приема сильно отличается от простой очереди сообщений.

[mibori]

Верно.
Логику, как у Эрланга можно реализовать самостоятельно:
1. Принять сообщение через recv, recvDelay, recvMaybe
2. Если сообщение не подошло, то вернуть его обратно в очередь через sendMe, sendMeBack

[rvp74]

Если возвращать в очередь сообщение то порядок его в очереди будет другой. А в Эрланге порядок насколько я помню важен.

[mibori]

неа

sendMe плюхнет сообщение в очередь сверху (как обычно)
А sendMeBack -- плюхнет снизу, откуда оно было вытащено recv. sendMeBack для того и задумывалась, чтобы сохранять порядок в очереди, если нужно вытащить только определенное сообщение.

[rvp74]

прием в Эрланге не ограничивается анализом одного элемента. Он сканирует всю очередь и вытягивает из любого места.

[mibori]

Ничего не мешает просканировать всю очередь.
Но да, мы упрёмся в производительность такого алгоритма.

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