हास्केल में दो इनपुटों की प्रतीक्षा, साथ ही

Question

शीर्षक थोड़ा अस्पष्ट हो सकता है। मेरा यही मतलब है:

कहें कि मेरे पास मेरे प्रोग्राम में इनपुट प्राप्त करने के दो तरीके हैं। पहला, कीबोर्ड getLine का उपयोग करके कुंजीपटल के माध्यम से होता है जो लाइन को पढ़े जाने तक ब्लॉक करता है। दूसरा, TChan के माध्यम से कहता है, जहां readTChan chan का उपयोग करके एक ब्लॉक में परिणाम होगा जब तक कि चैनल में कोई मान मौजूद न हो, जहां इसे पढ़ा जाएगा।

जो मैं पूरा करना चाहता हूं वह दोनों मानों का उपयोग कर एक थ्रेड का उपयोग करके और मेरे सीपीयू को 100% तक पहुंचने की अनुमति नहीं दे रहा है। पल दो मानों में से एक उपलब्ध है, यह प्राप्त किया जाता है और कार्यक्रम फिर से शुरू होता है। (Either का उपयोग करके सूचित करें कि दो मानों में से कौन सा मूल्य प्राप्त हुआ था।)

क्या यह संभव है?

बहुत बहुत धन्यवाद!

Answer 1

मुझे नहीं लगता कि "एक धागे का उपयोग करके" यहां समझ में आता है। TChan पर लिखने के लिए आपको पहले से ही कई हास्केल थ्रेड का उपयोग करना होगा। ऐसा करने के लिए आपको दो हास्केल थ्रेड का उपयोग करना चाहिए, और 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।

Answer 3

हैकेज पर "async" पैकेज में race :: IO a -> IO b -> IO (Either a b) सहायक फ़ंक्शन है।

एक साथ दो आईओ क्रियाएं चलाता है, इसलिए कोई भी getLine और अन्य MVar या जो कुछ भी हो सकता है। एक Either देता है जो दर्शाता है कि कौन सा पहले लौटा है (दूसरा रद्द कर दिया गया है)।

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