Go 语言从入门到实战
蔡超
Mobvista 技术副总裁兼首席架构师,前亚马逊(中国)首席软件架构师
48919 人已学习
新⼈⾸单¥59
课程目录
已完结/共 55 讲
第一章:Go语言简介 (4讲)
第二章:基本程序结构 (4讲)
第三章:常用集合 (3讲)
第四章:字符串 (1讲)
时长 16:47
第五章:函数 (2讲)
第六章:面向对象编程 (4讲)
第七章:编写好的错误处理 (2讲)
第八章:包和依赖管理 (2讲)
第九章:并发编程 (7讲)
第十章:典型并发任务 (5讲)
第十一章:测试 (3讲)
时长 11:48
时长 07:12
时长 06:15
第十二章:反射和Unsafe (3讲)
时长 08:18
时长 08:03
第十三章:常见架构模式的实现 (2讲)
第十四章:常见任务 (4讲)
时长 04:27
时长 05:14
第十五章:性能调优 (4讲)
第十六章:高可用性服务设计 (5讲)
Go 语言从入门到实战
登录|注册
留言
25
收藏
沉浸
阅读
分享
手机端
回顶部
当前播放: 27 | channel的关闭和广播
00:00 / 00:00
高清
  • 高清
1.0x
  • 2.0x
  • 1.5x
  • 1.25x
  • 1.0x
  • 0.75x
  • 0.5x
网页全屏
全屏
00:00
付费课程,可试看
01 | Go语言课程介绍
02 | 内容综述
03 | Go语言简介:历史背景、发展现状及语言特性
04 | 编写第一个Go程序
05 | 变量、常量以及与其他语言的差异
06 | 数据类型
07 | 运算符
08 | 条件和循环
09 | 数组和切片
10 | Map声明、元素访问及遍历
11 | Map与工厂模式,在Go语言中实现Set
12 | 字符串
13 | Go语言的函数
14 | 可变参数和defer
15 | 行为的定义和实现
16 | Go语言的相关接口
17 | 扩展与复用
18 | 不一样的接口类型,一样的多态
19 | 编写好的错误处理
20 | panic和recover
21 | 构建可复用的模块(包)
22 | 依赖管理
23 | 协程机制
24 | 共享内存并发机制
25 | CSP并发机制
26 | 多路选择和超时
27 | channel的关闭和广播
28 | 任务的取消
29 | Context与任务取消
30 | 只运行一次
31 | 仅需任意任务完成
32 | 所有任务完成
33 | 对象池
34 | sync.pool对象缓存
35 | 单元测试
36 | Benchmark
37 | BDD
38 | 反射编程
39 | 万能程序
40 | 不安全编程
41 | 实现pipe-filter framework
42 | 实现micro-kernel framework
43 | 内置JSON解析
44 | easyjson
45 | HTTP服务
46 | 构建RESTful服务
47 | 性能分析工具
48 | 性能调优示例
49 | 别让性能被锁住
50 | GC友好的代码
51 | 高效字符串连接
52 | 面向错误的设计
53 | 面向恢复的设计
54 | Chaos Engineering
55 | 结课测试&结束语
登录 后留言

全部留言(25)

  • 最新
  • 精选
Harry陈祥
老师您好。 传参 chan的时候,指针传参和值传参,看起来好像都可以work,而且复用的还是同一个通道。 那对于chan的值传参,copy的是什么?

作者回复: 这个在前面的课程中讲到过,chan是一个结构,这个结构在传递时是被复制的,其中的指针成员也会被复制到新的chan中,所以新旧两个chan会指向同一个内存区域

2019-03-24
2
4
郭星
package close import ( "fmt" "sync" "testing" ) // 发布者 func publisher(ch chan int) { go func() { for i := 0; i < 10; i++ { ch <- i } }() } // 接受者 func receiver(ch chan int, wg sync.WaitGroup) { go func() { //for { for i := 0; i < 10; i++ { fmt.Println(<-ch) } wg.Done() }() } func TestPubRe(t *testing.T) { var wg sync.WaitGroup ch := make(chan int) publisher(ch) wg.Add(1) receiver(ch, wg) wg.Wait() } 当WaitGroup使用值接收时为什么会报fatal error: all goroutines are asleep - deadlock!; ? 但当我使用指针接收时,就不会抛出deadlock

作者回复: go语言是之传递的,所有如果不用指针,receiver中的wg将是一个副本并指向不同的地址空间,所以wg.Done()并不会是外部不同副本的wg.Wait()解除等待

2020-07-14
3
3
Geek_427d0c
func dataProducer(ch chan int, wg *sync.WaitGroup) 老师,为什么你只把WaitGroup的指针传进去,而channel不传指针呢?编程(ch *chan int, wg *sync.WaitGroup)?

作者回复: 这个我在讲座中有讲过: 1 Go语言是都是传值的, 2 chan是一个结构体,被复制后其中的成员仍指向同一内存区域,类似的还有slice和map

2020-09-28
2
Steven Fung
func serviceOne() string { time.Sleep(time.Millisecond * 50) return "service 1 done" } func channelserviceone_2nd() chan string { retCh := make(chan string, 1) go func() { ret := serviceOne() fmt.Println("returned result.") retCh <- ret fmt.Println("service exited.") }() return retCh } func TestSelect(t *testing.T) { select { case ret := <-channelserviceone_2nd(): t.Log(ret) case <-time.After(time.Millisecond * 49): t.Log("time out") } } Output: === RUN TestSelect returned result. service exited. --- PASS: TestSelect (0.05s) /Users/stevenfung/Documents/code/go/src/github.com/CrazyPassion/go/helloworld/test/goroutine/goroutine_test.go:115: time out PASS ok github.com/CrazyPassion/go/helloworld/test/goroutine 0.058s Success: Tests passed. 老师,请教下这个问题,这个想不明白。按说serviceOne等待是50ms,49ms会超时,觉得应该看不到channelserviceone_2nd里面的打印,但是现在可以看到,并且也看到了超时的打印,这个是为什么?

作者回复: 这是因为你用的是buffered chan他是非阻塞的。所以只要外面的主协程在退出前能有时间让他运行完,他就可以输出。 你可以在TestSelect最后退出前加一个sleep 1秒,你就会发现更短的timeout一样会输出那些信息

2019-04-05
4
2
碧雪天虹
消费者可以通过 data,ok<-ch 来判断通道是否关闭, 生产者如何判断通道是否关闭? func TestCloseChannel(t *testing.T) { var wg sync.WaitGroup ch := make(chan int) dataProducer(ch, &wg) dataReceiver(ch, &wg) // 已经关闭通道, 生产者如何判断 close(ch) wg.Wait() }

作者回复: 通道应该由生产者来关闭,在关闭的channel上发送数据程序会panic

2019-10-21
1
Geek_427d0c
请教老师,go run和go test有什么不同呢? 我为了实现消费者每隔一秒打印0,1,2...,所以在生产者的协程里加了一个time.Sleep,也就是每隔一秒产生一个数字。IDE的debug模式和go run都能正常实现,但是go test看起来就像把输出缓存起来,然后等最外面额协程执行完,一下子打印所有的输出

作者回复: 在go test的运行程序中也要实用fmt输出,不要使用t.log. 通过go test -v运行

2020-09-28
黄三可
本节中的dataProducer方法,waitGroup传入的是指针,为什么在方法体中使用时,不需要像传入int指针一样,写成*wg.Done()

作者回复: WaitGroup类似于Channel这样的对象,他的定义是一个结构,虽然对象复制了,但是对象中成员还是指向同一地址空间的。

2020-02-10
面向加薪学习
老师,请教一个问题,如果做爬虫程序,其实程序启动就是死循环,初始化channel容量10个,有新数据就添加到channel里,然后一直不关闭,应该也不会有问题吧

作者回复: 这部分不会有问题。

2019-09-26
mamba
func TestCloseChannel(t *testing.T) { var wg sync.WaitGroup ch := make(chan int) wg.Add(1) dataProducer(ch, &wg) wg.Add(1) dataReceiver(ch, &wg) wg.Add(1) dataReceiver(ch, &wg) wg.Add(1) dataReceiver(ch, &wg) wg.Wait() } 想知道,为什么后面的两个 dataReceiver 也能得到数据, 难道这三个dataReceiver不是串行执行的吗?我的理解是第一个 dataReceiver 会把 dataProducer 产生的所有数据都读完 才退出。

作者回复: 虽然,语句是串行的,是线程的调度不是

2019-07-09
田佳伟
老师,当发送操作在执行的时候发现空的通道中,正好有等待的接收操作,那么它会直接把元素值复制给接收方,实际是这样的吗

作者回复: 实际上和方法调用的直接传递复制是不同的,还是通过chan来完成的

2019-06-25
收起评论