golang chan 的一些新手疑问

[SlipStupig]

作为 golang 新手，对 coroutine 有点疑问，代码如下：

func do_something(my_chl chan string):
    my_chl <- "ok"

func main():
   flag := 1
   new_chl := make(chan string, 1)
   for {
      if flag == 1{
        go do_something()
}else{
  break
}
}
     

在这种情况下，不知道会起多少个 coroutine 的情况下，如果只写 go 不使用 chan 似乎不会被执行，但是 chan 写成死循环就不会退出了，如果不写成死循环有什么办法可以不丢数据的情况下可以正常退出呢？

[ovear]

没懂 LZ 的问题。
如果主线程执行完毕退出了，其他的线程会被强行退出。
保证主线程不退出就好了

[SlipStupig]

@ovear 可能我没太讲清楚，我举个例子，比如我有一包数据要处理，这包数据有多少条我是不知道的，然后每次处理一条数据就起一个新的 go goroutine，然后目标函数会在 chennel 里面写数据，但是我要接受 chennel 里面的数据接受完，我写个 for 循环，我得写个数量吧，前提是我不知道有多少我写循环多少次去读 chennel 里面的数据呢？

[zhujinliang]

你肯定要知道到底执行了多少个 do_something，或者用一个计数器，统计一共执行了多少次。应该没有别的办法知道还有没有没执行完的 goroutines
PS：go 的函数有这种写法了？

[zhujinliang]

@SlipStupig 另外可以看看 sync 包里面的 WaitGroup 是不是你想要的

[ovear]

@SlipStupig range 循环取数据，用完 channel 后关闭
https://tour.golang.org/concurrency/4

[jihaiming]

一包数据? 是订阅式还是一次性获取?
只要不是阻塞的, for .. range ...就可以了吧. 或者 len 一下不行么

[SlipStupig]

@zhujinliang 也就是只能靠自己计数去取 chennel 里面的数据？

[wweir]

语言基础差不要紧，先把拼写搞对。学一门简单的语言，连里面很少的几个关键字都能拼写错误，这就是态度问题了

[bfbd]

别用全局 chan，当参数传给函数。https://github.com/aiportal/wechat-proxy/blob/master/wxproxy.go

[zhujinliang]

@SlipStupig 两个问题
一是设法知道有多少个正在运行的 goroutines，用 channel 或其它办法 block 住主线程，直到所有 goroutines 退出。这种场景 WaitGroup 更适合。channel 只是 block 住线程的一个手段，死循环 time.Sleep 也可以
另一个是往带缓冲的 channel 中写了数据，如何保证所有数据在退出前都被取出了，这个关闭 channel 后继续 for … range 即可

[scnace]

select

[mengzhuo]

LZ 需要把教程好好看看,顺便把基础和逻辑能力补一补

[rrfeng]

1. 发数据方计数，处理方也计数。处理完就退出
2. 双 chan，select，一个用于发送终止信号。
3. 单 chan，发送方最后发一个 "no more" 标记，for 就可以退出了。