【发布时间】:2015-12-29 14:51:27
【问题描述】:
我需要递归地读取一个目录结构,但是在我阅读完每个目录的所有条目后,我还需要执行一个额外的步骤。因此,我需要编写自己的递归逻辑(并且不能使用简单的filepath.Walk 例程)。然而,ioutil.ReadDir 和filepath.Glob 例程只返回切片。如果我要突破 ext4 或 xfs 的限制并拥有一个包含数十亿文件的目录怎么办?我希望 golang 有一个函数,它通过通道而不是排序切片返回未排序的 os.FileInfo 序列(或者更好的是原始字符串)。在这种情况下,我们如何有效地读取文件条目?
上面引用的所有函数似乎都依赖于 os/dir_unix.go 中的 readdirnames,而且,出于某种原因,它只是在看起来应该是的时候创建了一个数组轻松生成 gothread 并将值推送到通道中。这样做可能有合理的逻辑,但尚不清楚它是什么。我是 Go 新手,所以我也很容易错过一些对其他人来说显而易见的原则。
这是源代码,为方便起见:
func (f *File) readdirnames(n int) (names []string, err error) {
// If this file has no dirinfo, create one.
if f.dirinfo == nil {
f.dirinfo = new(dirInfo)
// The buffer must be at least a block long.
f.dirinfo.buf = make([]byte, blockSize)
}
d := f.dirinfo
size := n
if size <= 0 {
size = 100
n = -1
}
names = make([]string, 0, size) // Empty with room to grow.
for n != 0 {
// Refill the buffer if necessary
if d.bufp >= d.nbuf {
d.bufp = 0
var errno error
d.nbuf, errno = fixCount(syscall.ReadDirent(f.fd, d.buf))
if errno != nil {
return names, NewSyscallError("readdirent", errno)
}
if d.nbuf <= 0 {
break // EOF
}
}
// Drain the buffer
var nb, nc int
nb, nc, names = syscall.ParseDirent(d.buf[d.bufp:d.nbuf], n, names)
d.bufp += nb
n -= nc
}
if n >= 0 && len(names) == 0 {
return names, io.EOF
}
return names, nil
}
【问题讨论】:
标签: go