问题描述
我使用 jflex 词法分析器来解析大文件（~150 GB）。随着解析的进行，从文件中提取并作为参数传递给外部方法的小文档。如果可能，我想将这些文档用作 Akka 流的 Source，以便在正确管理背压的同时进一步转换并最终存储它们。
我阅读了队列，所以我使用了以下内容：
val queue = Source
.queue[String](bufferSize,akka.stream.OverflowStrategy.backpressure)
...
与方法一起推送
def push(document: String): Unit = queue.offer(document)
每次找到文档时，Lexer 都会调用它。
这是要走的路还是有更好（我的意思是更强大）的解决方案？
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）