一旦 Chan 中没有更多数据要处理，如何停止线程？

Question

我想使用Control.Concurrent.Chan。有一个大列表，提供者将其拆分为较小的列表。它将这些块写入通道。然后消费者从通道中读取这些块并进行处理。

一旦没有更多数据可以提供和消费，如何关闭分叉并返回结果？

使用TChan 可以检查通道是否为空。但是我想学，怎么用简单的Chan

我发现的大多数示例代码都只是使用forever $ getLine ...，然后从 main 开始，如果没有完成分叉，这不是问题，因为一旦 main 结束，分叉也会结束。我还没有找到一个好的消费者提供者示例，我可以从中了解如何与 Chans 合作

Answer 1

您可以像这样在Chan 基础上设计您的频道：

newtype MChan a = MChan (Chan (Maybe a))

newMChan :: IO (MChan a)
newMChan = MChan <$> newChan

closeMChan :: MChan a -> IO ()
closeMChan (MChan c) = writeChan c Nothing

writeMChan :: MChan a -> a -> IO ()
writeMChan (MChan c) = writeChan c . Just

readMChan :: MChan a -> IO (Maybe a)
readMChan (MChan c) = readChan c

所以，你可以关闭通道，消费者将一无所获，这将是停止线程的信号。