golang sync.WaitGroup 在 Linux 上未完成答案

【问题标题】：golang sync.WaitGroup doesn't complete on Linuxgolang sync.WaitGroup 在 Linux 上未完成
【发布时间】：2016-10-14 18:30:53
【问题描述】：

我有 ping 功能，在 Windows 上运行良好，但在 Linux 上不行。在 Linux 上，它会 ping 几台主机并停止（不退出）。

    func main() {
    ...
wg.Add(len(hosts))
    for _, ip := range hosts {
            go ping(ip, &wg, os)        
        }
        wg.Wait()
    ...
    }

我可以在 Windows 上 ping 数百台主机，但在 Linux 上却不行。看看https://github.com/irom77/go-public/blob/master/gping/main.go 的全部内容

    func ping(ip string, wg *sync.WaitGroup, os string ) {  
        _ , err := exec.Command("ping", os, *PINGCOUNT, "-w", *PINGTIMEOUT, ip).Output()    
        if err == nil {
            count++
            fmt.Printf("%d %s \n", count, ip)
        } 
wg.Done()
    }

打印结果时（在func ping中添加'result'）

result , err := exec.Command("ping", os, *PINGCOUNT, "-w", *PINGTIMEOUT, ip).Output()
fmt.Printf("%s\n", result)

我刚刚得到正确的输出，但它不会继续 ping 下一个 IP

....
--- 10.192.167.1 ping statistics ---
1 packets transmitted, 1 received, 0% packet loss, time 0ms
rtt min/avg/max/mdev = 476.564/476.564/476.564/0.000 ms

49 10.192.167.1

在这里期待更多的 IP（在 Windows 中很好）

【问题讨论】：

你在 WaitGroup 的什么地方添加和删除东西？
所以如果你没有在任何地方做wg.Done()，为什么这会结束呢？
如果某些命令没有返回，您需要调试原因。也许将它们直接连接到 stdout/stderr 并查看输出中是否有任何线索。如果它们正在返回，请获取堆栈跟踪并查看您阻塞的位置。
一般看起来没问题，但可能存在文件描述符限制问题或类似问题。
你没有打印错误，也许他们只是失败了？

标签： go

【解决方案1】：

您可能在这里忽略了恐慌，将您的 ping 函数更改为：

func ping(ip string, wg *sync.WaitGroup, os string ) {
    defer wg.Done()
    defer func(){
       if err := recover(); err != nil {
           fmt.Println("Error with:",ip,"err:",err)
       }
    }()
    result , err := exec.Command("ping", os, *PINGCOUNT, "-w", PINGTIMEOUT, ip).Output()
    fmt.Printf("%s\n", result)
    if err == nil {
        count++
        fmt.Printf("%d %s \n", count, ip)
    } else {
        //fmt.Printf("%s is dead\n", ip)
    }
}

这应该打印恐慌，如果它发生，以及保证调用 wg.Done()

// 注意：没有运行，但方向正确

【讨论】：

虽然恐慌会跳过非延迟的wg.Done，但原来的并没有恢复，所以恐慌很明显，而且该函数中的任何内容都不应该恐慌。
是的，你是对的，出于某种原因，我认为它被默默地丢弃了