channel 来实现互斥锁，优势是 trylock，timeout 吧，因为mutex 没有这些功能。否则的话，是不是用回 mutex 呢

老师好，我在测试扇出的例子的时候，在异步运行的时候出现了 panic: send on closed channel 的错误 // 扇出模式 func FunOut(ch <-chan int, n int, async bool) []chan int { var outs []chan int for i := 0; i < n; i++ { outs = append(outs, make(chan int)) } go func() { defer func() { for i := 0; i < len(outs); i++ { close(outs[i]) } }() for v := range ch { v := v for i := 0; i < n; i++ { i := i if async { go func() { outs[i] <- v }() } else { outs[i] <- v } } } }() return outs } // TestFunOut 异步操作 扇入模式 func TestFunOutAsync(t *testing.T) { dataStreams := []int{13, 44, 56, 99, 9, 45, 67, 90, 78, 23} inputChan := gen(dataStreams...) // 将数据写入一个channel ch := sq(inputChan) // 将所有的数据平方，再重新放入channel outArray := FunOut(ch, 3,true) length := len(outArray) t.Log("length of out channel:", length) var wg sync.WaitGroup wg.Add(length) for i := 0; i < length; i++ { c:=len(outArray[i]) fmt.Println("输入chan len", i, c) go func(in <-chan int, index int) { sum:=0 for item:=range in{ fmt.Println("item", index, item) sum+=item } fmt.Println("worker", index, sum) wg.Done() }(outArray[i], i) } wg.Wait() } 老师，我没看明白是哪里出错了？

老师想问一下上面所讲的击鼓传花的案例(流水线模式)的应用场景是？感觉就是按照顺序串行的话执行某些任务逻辑，不用goroutine的话也可以吧

老师好，我有两个问题 1、关于or done或者fan in模式，我之前在sof上看到过类似的问题，其中的高赞回答是说，启动与ch数量相等的goroutine，每个goroutine监听一个ch并把读到的结果放入一个收集ch的模式效率要比反射高，并且给出了测评数据，现在手机码字，不太好找到。但想和老师确认一下是不是后面go某个版本对反射做了优化呢？ 2、fanout模式里提到可以同步或者异步启动任务。在老师给出的示例代码中，异步启动的优势是什么呢？我猜老师想表达的是不是启动任务前可能还有一些耗时的准备操作？如果是这样的话，建议增加一个注释，否则感觉启动一个goroutine只是为了写一个ch，好像异步效率会更低

晁老师，这是我用多个goroutine 实现的 OrDone，但是有一个问题是在 执行close(orDone)是可能会引发panic，引发panic的原因是因为可能多次关闭一个chan, 请问我这个需要如何改才能不引发panic呢? func or3(channels ...<-chan interface{}) <-chan interface{} { if len(channels) == 0 { return nil } orDone := make(chan interface{}) for _, c := range channels { go func(ch <-chan interface{}) { <-ch close(orDone) // 可能会引发panic }(c) } return orDone }

一个基于 TCP 网络的分布式的 Channel ，请问这个有git仓库吗，想学习下

请问一下最后一段代码里面case <-done: 有什么用呢？

老师您好，在看Marcio Castilho 在 使用 Go 每分钟处理百万请求的例子的时候我很困惑，我认为双层管道是没有意义的，生产者直接发送job给消费者，额定数量的消费者直接进行并发接收并处理就可以达到同样控制并发的效果。为什么非要消费者把一个管道交给生产者，生产者在把job通过管道传递给消费者。我想请问一下这个步骤的作用是什么？

請問老師，channel這些模式都適合哪些塲景使用，能哪些優缺點能講講嗎

老师，请问下为什么在createCase函数里面，我们在创建一个SelectCase变量的时候，要使用reflect.ValueOf重新初始化一个的channel?