createPipeline 的文件打开问题

来源:3-5 完整外部排序

晓之海绵宝宝

2018-06-28 11:46

for i := 0; i < chunkCount; i++ {
   file.Seek(int64(i*chunkSize), 0)

   source := pipeline.ReaderSource(bufio.NewReader(file), chunkSize)
   sortResult = append(sortResult, source)
}

这里我将 os.Open(filename) 提取到 for 循环外部,我的理解是文件资源只需要打开一次就可以了,但结果是读取了 1 / 4,是哪里在 for 循环内关闭了文件资源吗?

写回答 关注

1回答

  • trojanq
    2018-07-12 21:54:20

    你试下把0改成1


搭建并行处理管道,感受GO语言魅力

通过搭建并行数据处理管道,展示go语言在并发编程方面的优势

19422 学习 · 81 问题

查看课程

相似问题