V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
SlipStupig
V2EX  ›  程序员

golang chan 的一些新手疑问

  •  
  •   SlipStupig · 2017-06-29 21:21:47 +08:00 · 2754 次点击
    这是一个创建于 2704 天前的主题,其中的信息可能已经有所发展或是发生改变。

    作为 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 写成死循环就不会退出了,如果不写成死循环有什么办法可以不丢数据的情况下可以正常退出呢?

    第 1 条附言  ·  2017-06-30 06:17:30 +08:00

    我主要还是想知道,当做一些操作的时候,我无法预测目标函数可能会执行多久,如果只写一个 for n in m

    会不会出现函数还执行完主线程就退出了呢?有什么好的办法可以知道coroutine已经全部执行完,然后通知主线程退出?

    13 条回复    2017-06-30 10:28:08 +08:00
    ovear
        1
    ovear  
       2017-06-29 21:27:33 +08:00
    没懂 LZ 的问题。
    如果主线程执行完毕退出了,其他的线程会被强行退出。
    保证主线程不退出就好了
    SlipStupig
        2
    SlipStupig  
    OP
       2017-06-29 21:34:38 +08:00
    @ovear 可能我没太讲清楚,我举个例子,比如我有一包数据要处理,这包数据有多少条我是不知道的,然后每次处理一条数据就起一个新的 go goroutine,然后目标函数会在 chennel 里面写数据,但是我要接受 chennel 里面的数据接受完,我写个 for 循环,我得写个数量吧,前提是我不知道有多少我写循环多少次去读 chennel 里面的数据呢?
    zhujinliang
        3
    zhujinliang  
       2017-06-29 21:37:21 +08:00 via iPhone
    你肯定要知道到底执行了多少个 do_something,或者用一个计数器,统计一共执行了多少次。应该没有别的办法知道还有没有没执行完的 goroutines
    PS:go 的函数有这种写法了?
    zhujinliang
        4
    zhujinliang  
       2017-06-29 21:39:12 +08:00 via iPhone
    @SlipStupig 另外可以看看 sync 包里面的 WaitGroup 是不是你想要的
    ovear
        5
    ovear  
       2017-06-29 21:41:06 +08:00
    @SlipStupig range 循环取数据,用完 channel 后关闭
    https://tour.golang.org/concurrency/4
    jihaiming
        6
    jihaiming  
       2017-06-29 21:42:58 +08:00
    一包数据? 是订阅式还是一次性获取?
    只要不是阻塞的, for .. range ...就可以了吧. 或者 len 一下不行么
    SlipStupig
        7
    SlipStupig  
    OP
       2017-06-30 06:02:39 +08:00
    @zhujinliang 也就是只能靠自己计数去取 chennel 里面的数据?
    wweir
        8
    wweir  
       2017-06-30 06:56:17 +08:00 via Android
    语言基础差不要紧,先把拼写搞对。学一门简单的语言,连里面很少的几个关键字都能拼写错误,这就是态度问题了
    bfbd
        9
    bfbd  
       2017-06-30 07:54:39 +08:00
    别用全局 chan,当参数传给函数。https://github.com/aiportal/wechat-proxy/blob/master/wxproxy.go
    zhujinliang
        10
    zhujinliang  
       2017-06-30 08:46:36 +08:00 via iPhone
    @SlipStupig 两个问题
    一是设法知道有多少个正在运行的 goroutines,用 channel 或其它办法 block 住主线程,直到所有 goroutines 退出。这种场景 WaitGroup 更适合。channel 只是 block 住线程的一个手段,死循环 time.Sleep 也可以
    另一个是往带缓冲的 channel 中写了数据,如何保证所有数据在退出前都被取出了,这个关闭 channel 后继续 for … range 即可
    scnace
        11
    scnace  
       2017-06-30 09:14:52 +08:00 via Android
    select
    mengzhuo
        12
    mengzhuo  
       2017-06-30 09:32:06 +08:00
    LZ 需要把教程好好看看,顺便把基础和逻辑能力补一补
    rrfeng
        13
    rrfeng  
       2017-06-30 10:28:08 +08:00   ❤️ 1
    1. 发数据方计数,处理方也计数。处理完就退出
    2. 双 chan,select,一个用于发送终止信号。
    3. 单 chan,发送方最后发一个 "no more" 标记,for 就可以退出了。
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   2815 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 25ms · UTC 11:46 · PVG 19:46 · LAX 03:46 · JFK 06:46
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.