6

我有以下代码：

import Control.Concurrent

sleepSort = mapM_ (forkIO . put)
  where put x = threadDelay (x*10000) >> print x

这对一组整数执行睡眠排序，并且工作正常，除了一个警告：

程序按顺序打印出数据集中的每个数字，就像它应该做的那样。但是，在打印完最后一个数字后，它会等待用户输入某个数字，然后回显该数字，然后完成。

我认为我在任何时候都不会要求用户输入，那么为什么会发生这种情况呢？

4

1 回答 1

7

发生这种情况是因为您的主线程不等待其他线程完成。您的程序启动了n 个线程，但主线程立即退出，并且您返回到解释器提示符。同时其他线程继续产生输出：

Prelude Control.Concurrent> sleepSort [1,2,3]
1
Prelude Control.Concurrent> 2
3

您可以通过向主线程添加延迟来解决此问题：

Prelude Control.Concurrent> sleepSort [1,2,3] >> threadDelay 10000
1
2
3

如果您正在运行已编译的程序，它会立即退出而不打印任何内容：

$ cat Test.hs
import Control.Concurrent

sleepSort = mapM_ (forkIO . put)
  where put x = threadDelay (x*1000) >> print x

main = sleepSort [1,2,3]
$ ghc --make -O2 Test.hs
[1 of 1] Compiling Main             ( Test.hs, Test.o )
Linking Test ...
$ ./Test
$

更新：您可以在函数中使用信号量，而不是添加对threadDelayto的调用：mainsleepSort

import Control.Concurrent
import Control.Concurrent.QSemN

sleepSort l = do
  qsem <- newQSemN 0
  mapM_ (forkIO . put qsem) l
  waitQSemN qsem n
  where
    n = length l
    put qsem x = threadDelay (x*1000) >> print x >> signalQSemN qsem 1

main = sleepSort [1,2,3]
于 2012-08-24T22:35:48.250 回答