Haskell. Erlang-style process communication.

[mibori]

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

Comments

[mibori]

Да, если дело надо сделать быстрее, бери Эрланг не задумываясь

см. примеры на http://community.livejournal.com/ru_lambda/81733.html

[antilamer]

А ведь concurrency у хаскелла, по слухам, еще резвее, чем у эрланга.
http://shootout.alioth.debian.org/gp4/benchmark.php?test=threadring&lang=all
http://shootout.alioth.debian.org/gp4/benchmark.php?test=chameneosredux&lang=all

[mibori]

давай.
убьёшь, если вдруг стану много не по теме постить.

[nealar]

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

[mibori]

для одной штуковины
а что за штуковина, если не секрет (просто интересно ввиду малого количества показательных примеров)

сделаю чуть по-другому
wow, что я упустил? :)

[nealar]

Штуковина такая: отлаживаю одну хреновину, которая лазает по HTTP, сеть тормозная дико - анлим, что с него взять. Поэтому хочу повесить тред, который будет сетевые запросы гонять, и швырять в него функциями, которые в сеть лазают. А сам параллельно висеть в GHCi.
По-другому сделаю потому что мне не нужен полноценный Эрланг, стандартного Chan должно хватить для всего. Просто пару недель назад я не знал о существовании такой библиотеки. А нормально запустить параллельность ещё и сегодня не получается. :)

[mibori]

А нормально запустить параллельность ещё и сегодня не получается.
А у тебя те треды, которые собственно коннектятся, через forkOS пускаются? (иначе у тебя каждый foreign unsafe-вызов (считай, коннект к серваку) будет блокировать все другие треды).

[rvp74]

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

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

[mibori]

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

[rvp74]

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

[mibori]

неа

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