发烧是不能洗的，退烧后过 1 天洗，那些坚持洗的只能说你年轻

小城市办公室全部都带了口罩

车多就要提前变道，到了路口再变迟了

@yuuko 是的，要准备东西拜神，不过大部分时间搞卫生

@turlin 年 30 洁癖，还要准备拜神

我家最没年味，年 30 爸妈全天搞卫生，比平时吃得还差

新手转弯变道记得看后视镜，脚不加油就放刹车上

主要是喉咙干疼，咳嗽

@sibowen 腾讯的对象存储，读写都是用 sdk 的

和我需求差不多，搞了个兆能 m2 刷 op ，不过没条件测试外网千兆

但是协程池 感觉复杂了一层，一定要这样？

用#1 介绍的协程池方法，目前可行

@sibowen 按你改的写和上面的一样，需要加个 sleep ，不然就显示不全，我要处理的是对象存储，通过发 http 请求，是不是和 os 文件系统底层不一样导致你的代码不行

```
wg.Add(1)
go func(och chan<- []cos.Object) {
defer wg.Done()
var wgg sync.WaitGroup
for _, perfix := range []string{"test", "tc"} {
wgg.Add(1)
go tools.GetObjs(cosClient, perfix, objchan, &wgg)
}
wgg.Wait()
close(och)
}(objchan)
```

目前代码是这样，问题是为什么后面不加 sleep 就只能随机显示 test ，tc 其中一个的内容？

```
func main() {
var wg sync.WaitGroup

objchan := make(chan []string, 10)

go func(och <-chan []string) {
for objs := range och {
println(objs)
}
}(objchan)

for _, perfix := range []string{"test", "tc"} {
wg.Add(1)
go Getfile(perfix, objchan, &wg)
}

wg.Wait()
time.Sleep(1)
}

func Getfile(dir string, filechan chan<- []string, wg *sync.WaitGroup) {
defer wg.Done()
// send files
...
filechan <- files
// 子目录递归
for _, dir := range dirs {
wg.Add(1)
go Getfile(dir, filechan)
}
}
```

@xingjue channel 能重新打开？

@sibowen
@zjj19950716
@bebop
我试试，谢谢

发送端效率 》 接收端效率，所以发送端先关闭可能造成结果不完整？
所以还是在接收端处理 chan 关闭比较好？

@bebop
@sduoduo233
改成了在历遍时候 add ，但是结果有点奇怪，只能随机处理"test", "tc"中的一个。
在 wg.Wait()后面 time.Sleep ，才能显示完整

@bebop 问题是递归，Getfile 不知道会跑多少次