-
- Ganjr 2020-07-26
- package main
import (
"bufio"
"ccmouse/gointro/pipeline"
"fmt"
"os"
)
func main() {
p := createPipeline("small.in", 512, 4)
writeToFile(p, "small.out")
printFile("small.out")
}
func printFile(filename string) {
file, err := os.Open(filename)
if err != nil {
panic(err)
}
defer file.Close()
p := pipeline.ReadSource(file, -1)
for v := range p {
fmt.Println(v)
}
}
func writeToFile(p <-chan int, filename string) {
file, err := os.Create(filename)
if err != nil {
panic(err)
}
defer file.Close()
writer := bufio.NewWriter(file)
defer writer.Flush()
pipeline.WriteSink(writer, p)
}
func createPipeline(
filename string,
filesize, chunkCount int) <-chan int {
chunkSize := filesize / chunkCount
var sortResults []<-chan int
for i := 0; i < chunkCount; i++ {
file, err := os.Open(filename)
if err != nil {
panic(err)
}
file.Seek(int64(i * chunkSize), 0)
source := pipeline.ReadSource(
bufio.NewReader(file), chunkSize)
sortResults = append(sortResults, pipeline.InMemSort(source))
}
return pipeline.MergeN(sortResults...)
} - 0赞 · 0采集
-
- 霜花似雪 2018-11-12
外部排序Pipeline
-
截图0赞 · 0采集
-
- android_coco 2018-04-06
func writhToFile(p <-chan int, fielname string) { file,err :=os.Create(fielname) if err != nil { panic(err) } defer file.Close() writer := bufio.NewWriter(file) defer writer.Flush() pipeline.WriterSink(writer,p) }- 0赞 · 0采集
-
- 糊你大熊脸 2017-12-26
- 外部排序的 图解
-
截图0赞 · 0采集
数据加载中...