Lassen Sie sich vom ersten Thread zur Folge abgeschlossen

Question

sagen, dass ich zwei lange laufende Prozesse in zwei separaten Threads in Haskell berechnen will. Allerdings interessiert mich nur das Ergebnis vom ersten fertig. Wie würde ich das tun?

Beispiel (Pseudocode):

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

Das async Paket tut dies, und ist jetzt Teil der 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

Wenn Sie wollen, dass die länger laufenden Thread getötet Sie verwenden können: http://hackage.haskell.org/package/unamb

Sonst könnte man das Gleiche wie unamb tun, aber die killThread auslassen.

Answer 3

Wenn Sie mit IO Threads arbeiten würden, könnten Sie auch das neueste parallel-io Paket verwenden, insbesondere parallelFirst. Diese