하스켈의 두 입력을 동시에 기다리는 중

Question

제목이 다소 흐릿 할 수 있습니다. 이것은 내가 의미하는 바입니다 :

두 가지 방법으로 프로그램에 입력 할 수 있습니다. 첫 번째는 키보드를 통해 getLine 함수를 사용하여 행이 읽힐 때까지 차단합니다. 다른 하나는 TChan을 통해 말하며, readTChan chan을 사용하면 채널에 값이 나타날 때까지 블록이 만들어지고 읽히게됩니다.

모두 값을 기다릴 수 있습니다. 단일 스레드를 사용하고 CPU가 100 %로 이동하지 못하도록합니다. 두 값 중 하나를 사용할 수있게되면이 값을 가져와 프로그램을 다시 시작합니다. (두 가지 값 중 어느 것을 수신했는지 알려면 Either을 사용하십시오.)

이것이 가능합니까?

대단히 감사합니다!

Answer 1

"단일 스레드 사용"이 여기에 적합하다고 생각하지 않습니다. 어쨌든 TChan에 쓰려면 하스켈 스레드를 여러 개 사용해야합니다. 이 작업을 수행하려면 두 개의 Haskell 스레드를 사용해야하며 MVar 또는 유사한 것을 사용하여 도착한 첫 번째 결과를 전달해야합니다. 예를 들면 다음과 같습니다.

module Main where 

import System.IO 
import Control.Concurrent 
import Control.Concurrent.MVar 
import Control.Concurrent.STM 
import Control.Concurrent.STM.TChan 

main = do 
    chan <- newTChanIO 
    forkIO (threadTChanWrite chan) 
    threadMultiplexedRead chan 

threadTChanWrite chan = do 
    threadDelay 5000000 
    atomically $ writeTChan chan 3 

threadMultiplexedRead chan = do 
    mvar <- newEmptyMVar 
    forkIO (threadKeyboardRead mvar) 
    forkIO (threadTChanRead mvar chan) 
    v <- readMVar mvar 
    print v 

threadKeyboardRead mvar = do 
    str <- getLine 
    putMVar mvar (Right str) 

threadTChanRead mvar chan = do 
    v <- atomically (readTChan chan) 
    putMVar mvar (Left v) 

적절하게 구현하면 나중에 남아있는 스레드가 정리됩니다 (btw).

Answer 2

나는 내 프로그램에 입력을 얻는 두 가지 방법이

당신은 공유 채널에 결과를 기록, 각각의 입력을 기다릴 2 개 스레드, 입력 소스 당 하나를 사용할 수 있어야합니다 또는 mvar가 제 3 스레드에 의해 관리된다.

Answer 3

hackage의 "async"패키지에는 race :: IO a -> IO b -> IO (Either a b) 도우미 기능이 있습니다.

두 개의 IO 작업을 동시에 실행하므로 하나는 getLine 일 수 있고 다른 하나는 MVar 또는 그 밖의 모든 차단 작업을 수행 할 수 있습니다. Either을 반환합니다. 어느 것이 먼저 반환되었는지 (다른 하나는 취소됨)를 나타냅니다.

https://hackage.haskell.org/package/async-2.0.2/docs/Control-Concurrent-Async.html#v:race