慕课网

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

最热最新

plzpass 06:38

并发

查看全部

0 采集收起来源：go语言设计
2022-10-19
legend达 08:02

很多goroutine映射到一个线程。多对1的关系。

chan是go里的一等公民。我们可以往chan里放不同类型的数据。也可以从一个声明的chan里取数据。

demo 从8:00开始

查看全部

0 采集收起来源：Hello World并发版
2022-01-16
慕侠2314331 00:18

- pipeline：一個library

查看全部

0 采集收起来源：基础节点
2021-08-10
慕侠2314331 00:18

- pipeline：一個library

查看全部

0 采集收起来源：基础节点
2021-08-10
poppowerlb2 04:30

Go语言编程范式：面向接口、函数式编程、并发编程。

查看全部

0 采集收起来源：go语言设计
2020-10-26
一只小马甲甲 00:57

各个编程语言的使用场景.

查看全部

0 采集收起来源：go语言设计
2020-10-25
慕后端7002444 08:13
```
外部排序pipeline
```
查看全部

0 采集收起来源：归并排序算法
2020-08-31
慕后端7002444 06:25

节点的组装，
传统语言与Go语言对比

查看全部

0 采集收起来源：归并排序算法
2020-08-31
Ganjr
```
go run [file]
go build [file]
[bin]
```
查看全部

0 采集收起来源：Hello World及网络版
2020-08-16
Ganjr
进一步学习
- go tool tour
- http://docscn.studygolang.com/doc/
- 期待我的 go 语言实战课
查看全部

1 采集收起来源：结语
2020-08-02
Ganjr 02:27
go 语言三大特色
1. 面向接口- Reader/ Writer 接口的使用
2. 函数式编程
3. 并发编程
查看全部

1 采集收起来源：结语
2020-08-02
Ganjr 00:46

课程回顾
原始数据

查看全部

1 采集收起来源：结语
2020-08-02
Ganjr 02:09

网络的扩展

查看全部

0 采集收起来源：网络版外部排序
2020-07-30
Ganjr 01:09

网络的扩展

查看全部

0 采集收起来源：网络版外部排序
2020-07-30
Ganjr
单机版外部排序 pipeline
- Reader Source 节点-支持分块
- Mergen-搭建归并节点组
- pipeline 的搭建及运行——CPU 及线程数量的观测
查看全部

0 采集收起来源：网络版外部排序
2020-07-30
Ganjr
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 采集收起来源：完整外部排序
2020-07-26

首页上一页1 2 3 4 5 6 7 下一页尾页

0/150

提交

取消

开始学习

课程须知: 1、了解一门编程语言，对基本算法如排序有了解

老师告诉你能学到什么？: 1、go语言的历史和设计初衷 2、go语言的安装与开发环境 3、简单的go语言程序 4、了解go语言并发编程 5、实现一个并行数据处理管道