Uzyskaj wynik pierwszego wątku ukończonego

Question

Powiedz, że chcę obliczyć dwa długotrwałe procesy w dwóch osobnych wątkach w Haskell. Jednak zależy mi tylko na wyniku od pierwszego. Jak to zrobić?

Przykład (pseudo kod):

thread1 = spark $ long_running some_arg1 
thread2 = spark $ long_running some_arg2 
result = first_done thread1 thread2 -- Maybe even first_done [thread1, thread2]? 

Answer 1

Wykonuje to pakiet async i jest teraz częścią Haskell Platform.

import Control.Concurrent.Async 
import Control.Concurrent (threadDelay) 

main :: IO() 
main = do 
    x <- async (threadDelay 2000000 >> return 1) 
    y <- async (threadDelay 1000000 >> return 2) 
    (_, res) <- waitAnyCancel [x, y] 
    print (res :: Int) 

Answer 2

Jeśli chcesz już uruchomiony wątek zabity można użyć: http://hackage.haskell.org/package/unamb

przeciwnym razie można zrobić to samo, co unamb jednak pominąć killThread.

Answer 3

Jeśli chcesz pracować z IO wątków, można również użyć najnowszy pakiet parallel-io, w szczególności parallelFirst.