我在 clojure.java.io/copy 函数的实现中发现了一个奇怪的行为。
https://github.com/clojure/clojure/blob/ee1b606ad066ac8df2efd4a6b8d0d365c206f5bf/src/clj/clojure/java/io.clj#L391
(defn copy
"Copies input to output. Returns nil or throws IOException.
Input may be an InputStream, Reader, File, byte[], char[], or String.
Output may be an OutputStream, Writer, or File.
Options are key/value pairs and may be one of
:buffer-size buffer size to use, default is 1024.
:encoding encoding to use if converting between
byte and char streams.
Does not close any streams except those it opens itself
(on a File)."
{:added "1.2"}
[input output & opts]
(do-copy input output (when opts (apply hash-map opts))))
实际的复制操作是从 InputStream 复制到 OutputStream 时在这里实现的。
https://github.com/clojure/clojure/blob/ee1b606ad066ac8df2efd4a6b8d0d365c206f5bf/src/clj/clojure/java/io.clj#L306
(defmethod do-copy [InputStream OutputStream] [^InputStream input ^OutputStream output opts]
(let [buffer (make-array Byte/TYPE (buffer-size opts))]
(loop []
(let [size (.read input buffer)] ;;; XXX point 1
(when (pos? size) ;;; XXX point 2
(do (.write output buffer 0 size)
(recur)))))))
这里的点1处的 .read 函数是 https://docs.oracle.com/javase/7/docs/api/java/io/InputStream.html#read(byte[])
JavaDoc 表明以下内容
从输入流中读取一些字节并将其存储到缓冲数组 b 中。实际读取的字节数作为整数返回。该方法在输入数据可用、检测到文件末尾或抛出异常时阻塞。
如果 b 的长度为零,则不读取任何字节,并返回 0;否则,尝试读取至少一个字节。如果没有字节可用,因为流已到达文件末尾,则返回值 -1;否则,至少读取一个字节并将其存储在 b 中。
这意味着返回值 -1 表示流的末尾,而返回值 0 并不一定表示流的末尾。然而,上述代码中的点2处的条件在 .read 返回小于 1 的值时停止递归。
考虑一个在这种情况下 .read 在连续调用中返回此值序列的例子
1024, 0, 1024, 201, -1
clojure.java/io 仅复制了前 1024 字节,而当整个流有 2249 字节时,这是预期的行为吗?这里条件1应该是 (not (neg? size))
吗?
我也把这个问题发布到了 google groups: https://groups.google.com/forum/#!topic/clojure/XzpPPXXhgM4