Haskell工作池

Question

我对Haskell编程感兴趣，但我想创建一个工作池系统​​，并且我想知道这是否会成为Haskell中的问题。

以下是Ruby中的一个简单程序。在执行的一个线程中，单词来自用户并添加到列表中。在另一个线程中，单词从列表中取出并以某种方式处理（在这种情况下，反转并打印回用户）。

words = [] 

# Create new thread to take words from array, one at a time, and process them 
t = Thread.new { 
    loop do 
    unless words.empty? 
     word = words.pop 
     break if word == 'quit' 
     sleep 1 
     puts word.reverse 
    end 
    end 
} 

# Take words from user and add to array 
loop do 
    puts "Enter word:" 
    word = gets.chomp 
    words << word 
    break if word == 'quit' 
end 

t.join 

什么是等价的Haskell代码？

Answer 1

这是一个非常接近的翻译。

Chan是一个消息在Haskell线程之间传递的FIFO队列。

下面我使用MVar来等待假脱机程序退出。这就像一个常规的可变变量，但它受到互斥体的保护。它可以是空的（只允许put，take等待）或全部（只允许take，put等待）。

我还使用下面的Haskell线程，它可能在单独的OS级别的线程上运行 - Haskell运行时选择它。与OS线程相比，Haskell线程非常便宜。

参见例如Real World Haskell有关更多讨论。

{-# OPTIONS -Wall #-} 
module JobPool where 

import Control.Monad (when) 
import Control.Concurrent 

spooler :: Chan String -> MVar() -> IO() 
spooler ch stop = do 
    word <- readChan ch 
    if word == "quit" 
    then putMVar stop() 
    else do 
     threadDelay 1000000 -- us 
     putStrLn (reverse word) 
     spooler ch stop 

main :: IO() 
main = do 
    stop <- newEmptyMVar 
    ch <- newChan 
    _ <- forkIO $ spooler ch stop 
    let loop = do 
      word <- getLine 
      writeChan ch word 
      when (word /= "quit") loop 
    loop 
    takeMVar stop