如何在 Clojure 中使用 java.util.stream.Stream？

Question

(import java.nio.file.Files)(import java.nio.file.Paths)(import java.util.stream.Stream)(def path   (Paths/get "."     (into-array ["data" "10000000.test.log"])))(def stream   (Files/lines path))这样我就有了：stream#object[java.util.stream.ReferencePipeline$Head 0x50129b8f"java.util.stream.ReferencePipeline$Head@50129b8f"]有没有办法在不耗尽内存的情况下迭代它？对SO的建议并没有多大帮助。文件大约1G。

Answer 1

做与在 java 中做的同样的事情。对其调用互操作方法，例如(.map stream ...)或其他任何方法，然后将其收集到最后的列表中，或减少它，或任何您需要执行的操作。

Clojure 函数不实现流所需的接口，例如 java.util.function.Function，因此您需要使用 reify 而不是简单的fn：

(.map stream (reify java.util.function.Function (apply [this x] (foo x))))

Answer 2

您可能需要研究一个名为ike.cljj 的库来了解一些互操作细节。

Answer 3

我想迭代流 Java/命令式风格以避免堆爆。我不需要减少流，我需要处理每一行并取出一个字段并将其发送出去。我认为为此我可能最好使用doseq。

(doseq 
  [l (iterator-seq (.iterator stream))] 
    (println l))