Golang Go语言中请教 goroutine 通信写法问题

可以是可以. 那 chan 的 buffer 得足够大.要不然就死锁了吧?

Reading Material： https://go.dev/blog/pipelines

拆成两个问题：
1. 多个 goroutine 如何读取消息
- 使用 fan-in 和 fan-out pattern ，将其结果汇总到一个 channel 里，此时原始 goroutine 关闭 channel 不影响；
- 直接 select 多个 channel 。
2. 当某个 gorutine 退出时如何通知其他的 goroutine 退出：
a. （可选）如果需要等待其他 goroutine 退出的话，使用 sync.WaitGroup 等待；
b. 使用一个 exitChannel （ chan struct{} 就行），接收到退出信号的时候直接由 main close ，其他 goroutine 使用 for { select { case <- exitChannel: return default: logic} } 的形式来正确接受退出信号

你们真强，我都没看明白楼主在说啥。

第二种吧，逻辑清晰，实现简单

套路都是 main routine 去 range channel ，剩下的问题就是如何 close channel ，这个建议你搜索“如何优雅关闭 channel”，学习 channel 使用的几个套路。

package main

import (
“fmt”
“math/rand”
“sync”
“time”
)

func main() {

// init var
ch := make(chan int)
wg := &sync.WaitGroup{}

// goroutine1, 2, 3
for i := 0; i < 3; i++ {
wg.Add(1)
go task(wg, ch)
}

// read chan data
go func() {
for val := range ch {
fmt.Println(val)
}
}()

// wait group
wg.Wait()
close(ch)

// close fast, can`t read all chan data
time.Sleep(time.Second)
}

func task(wg *sync.WaitGroup, ch chan int) {
defer wg.Done()

ts := rand.Intn(3) + 1
time.Sleep(time.Second * time.Duration(ts))

ch <- ts
}