- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我见过有人推荐管道/管道库来执行各种惰性 IO 相关任务。这些库到底解决了什么问题?
此外,当我尝试使用一些 hackage 相关的库时,很可能存在三个不同的版本。示例:
这让我很困惑。对于我的解析任务,我应该使用 attoparsec 还是 Pipes-attoparsec/attoparsec-conduit?与普通的 attoparsec 相比,管道/导管版本给我带来了什么好处?
最佳答案
惰性 IO 的工作原理如下
readFile :: FilePath -> IO ByteString
其中 ByteString
保证只能逐 block 读取。为此,我们(几乎)可以写
-- given `readChunk` which reads a chunk beginning at n
readChunk :: FilePath -> Int -> IO (Int, ByteString)
readFile fp = readChunks 0 where
readChunks n = do
(n', chunk) <- readChunk fp n
chunks <- readChunks n'
return (chunk <> chunks)
但在这里我们注意到,IO 操作 readChunks n'
是在返回可用的 chunk
部分结果之前执行的。这意味着我们一点也不懒惰。为了解决这个问题,我们使用 unsafeInterleaveIO
readFile fp = readChunks 0 where
readChunks n = do
(n', chunk) <- readChunk fp n
chunks <- unsafeInterleaveIO (readChunks n')
return (chunk <> chunks)
这会导致 readChunks n'
立即返回,仅当强制执行该 thunk 时才会执行 IO
操作。
这是危险的部分:通过使用 unsafeInterleaveIO
,我们将一堆 IO
操作延迟到了 future 的不确定点,这些操作取决于我们如何使用我们的 block ByteString
。
我们想要做的是在对 readChunk
的调用和对 readChunks
的递归之间插入一个 block 处理步骤。
readFileCo :: Monoid a => FilePath -> (ByteString -> IO a) -> IO a
readFileCo fp action = readChunks 0 where
readChunks n = do
(n', chunk) <- readChunk fp n
a <- action chunk
as <- readChunks n'
return (a <> as)
现在我们有机会在加载每个小块后执行任意 IO
操作。这让我们可以增量地完成更多工作,而无需将 ByteString
完全加载到内存中。不幸的是,它的组合性不是很好——我们需要构建我们的消费action
并将其传递给我们的ByteString
生产者才能运行。
这本质上就是管道所解决的问题——它使我们能够轻松地编写有效的协同例程。例如,我们现在将文件读取器编写为 Producer
,可以将其视为在其效果最终运行时“流式传输”文件 block 。
produceFile :: FilePath -> Producer ByteString IO ()
produceFile fp = produce 0 where
produce n = do
(n', chunk) <- liftIO (readChunk fp n)
yield chunk
produce n'
请注意此代码与上面的 readFileCo
之间的相似之处 - 我们只需将对协程操作的调用替换为 yield
我们的 chunk
到目前为止已经制作完成。对 yield
的调用构建了一个 Producer
类型,而不是我们可以与其他 Pipe
组合的原始 IO
操作类型以构建一个称为 Effect IO ()
的良好消费管道。
所有这些管道构建都是静态完成的,而不实际调用任何 IO
操作。这就是 pipes
让您更轻松地编写协程的方式。当我们在 main
IO
操作中调用 runEffect
时,所有效果都会立即触发。
runEffect :: Effect IO () -> IO ()
那么为什么要将 attoparsec
插入 pipes
中?嗯,attoparsec
针对延迟解析进行了优化。如果您以有效的方式生成输入到 attoparsec 解析器的 block ,那么您将陷入僵局。你可以
pipes
(或conduit
)构建一个协程系统,其中包括惰性attoparsec
解析器,允许它在尽可能少的情况下运行根据需要输入,同时在整个流中尽可能延迟地生成解析值。关于haskell - Pipes/conduit试图解决什么问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/22742001/
@Cacheable在同一类中方法调用无效 上述图片中,同一个类中genLiveBullets()方法调用同类中的queryLiveByRoom()方法,这样即便标识了Cacheable标签,
目录 @Transaction注解导致动态切换更改数据库失效 使用场景 遇到问题 解决 @Transaction
@RequestBody不能class类型匹配 在首次第一次尝试使用@RequestBody注解 开始加载字符串使用post提交(貌似只能post),加Json数据格式传输的时候,
目录 @Autowired注入static接口问题 @Autowired自动注入普通service很方便 但是如果注入static修饰的serv
目录 @RequestBody部分属性丢失 问题描述 JavaBean实现 Controller实现
目录 解决@PathVariable参数接收不完整的问题 今天遇到的问题是: 解决办法: @PathVariable接受的参
这几天在项目里面发现我使用@Transactional注解事务之后,抛了异常居然不回滚。后来终于找到了原因。 如果你也出现了这种情况,可以从下面开始排查。 1、特性 先来了解一下@Trans
概述: ? 1
场景: 在处理定时任务时,由于这几个方法都是静态方法,在aop的切面中使用@Around注解,进行监控方法调用是否有异常。 发现aop没有生效。 代码如下:
最近做项目的时候 用户提出要上传大图片 一张图片有可能十几兆 本来用的第三方的上传控件 有限制图片上传大小的设置 以前设置的是2M&nb
我已经实现了这个SCIM reference code在我们的应用程序中。 我实现的代码确实通过了此postman link中存在的所有用户测试集合。 。我的 SCIM Api 也被 Azure 接受
我一直对“然后”不被等待的行为感到困扰,我明白其原因。然而,我仍然需要绕过它。这是我的用例。 doWork(family) { return doWork1(family)
我正在尝试查找 channel 中的消息是否仍然存在,但是,我不确定如何解决 promise ,查看其他答案和文档,我可以看到它可能是通过函数实现的,但我是不完全确定如何去做。我希望能在这方面获得一些
我有以下情况: 同一工作区中的 2 个 Eclipse 项目:Apa 和 Bepa(为简洁起见,使用化名)。 Apa 项目引用(包括)Bepa 项目。 我在 Bepa 有一个类 X,具有公共(publ
这个问题已经有答案了: Why am I getting a NoClassDefFoundError in Java? (31 个回答) 已关闭 6 年前。 我正在努力学习 spring。所以我输入
我正在写一个小游戏,屏幕上有许多圆圈在移动。 我在两个线程中管理圈子,如下所示: public void run() { int stepCount = 0; int dx;
我在使用 Sympy 求解方程时遇到问题。当我运行代码时,例如: 打印(校正(10)) 我希望它打印一个数字 f。相反,它给我错误:执行中止。 def correction(r): from
好吧,我制作的每个页面都有这个问题。我不确定我做错了什么,但我所有的页面都不适用于所有分辨率。可能是因为我使用的是宽屏?大声笑我不确定,但在小于宽屏分辨率的情况下,它永远不会看起来正确。它的某些部分你
我正在尝试像这样进行一个非常简单的文化 srting 检查 if(culture.ToUpper() == "ES-ES" || "IT-IT") { //do something } else
Closed. This question is off-topic. It is not currently accepting answers. Learn more。 想改进这个问题吗?Upda
我是一名优秀的程序员,十分优秀!