ハスケルの生産者と消費者の問題？

Question

Haskellのような関数型プログラミング言語でプロデューサ/コンシューマを実装するにはどうすればいいですか？命令言語とはどのように異なるのでしょうか？関数型プログラミング言語の私の理解は原始的です。どんな助けもありがとう。チャネルを通過したプリエンプティブスレッドとメッセージを使用して

Answer 1

プロデューサ/コンシューマ抽象化：

import Data.Char 
import Control.Concurrent 
import Control.Concurrent.Chan 

main = do 
    c <- newChan 
    cs <- getChanContents c  -- a lazy stream of events from eventReader 
    forkIO (producer c)   -- char producer 
    consumer cs 

    where 
    -- thread one: the event producer 
    producer c = forever $ do 
     key <- getChar 
     writeChan c key 

    -- thread two: the lazy consumer 
    consumer = mapM_ print . map shift 
     where shift c | isAlpha c = chr (ord c + 1) 
          | otherwise = c 

あなたはErlangで同様のモデルを使用します。コンシューマとプロデューサを表すスレッド、およびそれらの間にメッセージの共有パイプがあり、それぞれ非同期的に動作します。

Answer 2

donsの根底にあるメカニズムはMVarと呼ばれ、値のための必須の並列コンテナです。あなたはMVarに出入りする "put"と "get"を行います。空のMVarを得ることは、完全なものを入れることと同じです。これは同時に通信メカニズムと同期メカニズムです。 Monsoon/* tプロジェクトの一環として、Arvindによって発明されたと思います。パラレルハスケルのpH方言を説明する美しいbook by Nikhil and Arvindがあります。アイデアの多くはGHCに採用されており、この本は読み解く価値があります。

Answer 3

ノーマンとドンで言及したステートフルなアプローチに加えて、あなたはまた、生産者と消費者としての正常な機能のアプリケーションと怠惰と考えることができます。ここ

は自然数のプロデューサーである：そのようなPythonでC＃またはジェネレータでyield returnとして

squares = map (\x -> x * x) nats 

プロデューサー：

nats = [1..] 

そしてここでは、これらの数字の二乗を計算し、消費者でありますハスケルの単純な遅延リストのように、しばしば以下のように表現することができます。