Haskell 异步：在 withAsync

如何解决Haskell 异步：在 withAsync

我正在编写一个 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 之类的东西？