问题描述
我正在编写一个 Monad 转换器,要运行该转换器,我需要生成一个 IO 线程,该线程将元素写入主线程可以访问的 TQueue。但是,withAsync 的所有版本都没有提供正确的签名。我需要一个像
这样的签名(Monadio m) => IO a -> (Async a -> m b) -> m b
我尝试了解除异步,但它有很多限制,并且主线程和衍生线程都在同一个 Monad 中。
或者,因为 Control.Concurrent.Async 说 withAsync 等价于
withAsync action inner = mask $ \restore -> do
a <- async (restore action)
restore (inner a) `finally` uninterruptibleCancel a
另一种解决方案是具有类似类型签名的掩码版本
mask :: (MonadMask m) => ((forall a n. (MonadMask n) => n a -> n a) -> m b) -> m b
我最接近解决方案的是以下代码,我很确定它不起作用,但我不能确定,因为我不完全了解掩码的工作原理。
withAsyncT :: (Monadio m,MonadMask m) => IO a -> (Async a -> m b) -> m b
withAsyncT action inner = mask $ \restore -> do
a <- liftIO $ asyncWithUnmask (\rstr -> rstr action)
restore (inner a) `finally` (liftIO $ uninterruptibleCancel a)
是否有合理的解决方案来获得这样的 withAsync?还是我必须使用 unliftio 之类的东西?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)