比较两个独立 goroutine 中的两个切片并使用 sync.Waitgroup 时挂起的 goroutine答案

【问题标题】：Hung goroutines when comparing two slices in two separate goroutines and using sync.Waitgroup比较两个独立 goroutine 中的两个切片并使用 sync.Waitgroup 时挂起的 goroutine
【发布时间】：2016-04-21 09:56:35
【问题描述】：

我正在学习 goroutines，并且在两个 goroutines 中比较两个切片，这是一个无限循环来永远比较它，这可能不是最好的例子，我不知道为什么会这样挂了。

for ;; {
    var wg sync.WaitGroup
    wg.Add(2)
    go FindinFirst(&Arr1, &Arr2, AddChan, &wg)
    go FindinSecond(&Arr2, &Arr1, DelChan, &wg)
    counter := 0
        for ; ; {
            select {
            case Add, ok := <- AddChan:
                if ok == true {
                    for k, v := range Add  {
                        fmt.Println(k, ":", v)
                    }
                }else {
                    counter += 1
                }
            case Del, ok := <- DelChan:
                if ok == true {
                    for k, v := range Del  {
                        fmt.Println(k, ":", v)
                    }
                }else {
                    counter += 1
                    }
            }
            if counter == 2{
                break
            }
            wg.Wait()
}

函数 FindinFirst 是

func FindinFirst(Arr1, Arr2 *[]string, AddChan chan string, wg *sync.WaitGroup){
defer wg.Done()
fmt.Println("Starting FindinFirst")
defer close(AddChan)
for _, i := range *Arr1 {
    if IfExists(i, *Arr2) {
        fmt.Println("Exists")
        continue
    } else {
        AddChan <- i

    }
}
}

函数 FindinSecond 是

func FindinSecond(Arr2, Arr1 *[]string, DelChan chan string, wg *sync.WaitGroup){
defer wg.Done()
fmt.Println("Starting FindinSecond")
defer close(DelChan)
for _, i := range *Arr2 {
    if IfExists(i, *Arr1) {
        fmt.Println("Exists")
        continue
    } else {
        DelChan <- i

    }
}
}

而IfExists 只是一个函数，如果该值存在于切片中，则返回一个布尔值。

但是，例程只打印了一个值，我不确定为什么会发生这种情况。两个切片都有接近 1000 个值，并且都有唯一性。代码有什么问题？

【问题讨论】：

标签： go concurrency channel goroutine

【解决方案1】：

我认为在这里使用等待组没有任何用处...由于您在 for 循环中使用通道，因此将 wg.wait() 放入将阻塞，直到所有等待组完成。

在这种情况下，将值放入 AddChan 将阻塞，除非有人在等待它。该代码仅适用于第一种情况，之后它会挂起。

您可以删除 wg.wait() 和外部 for 循环，它会起作用。

func main() {
    Arr1 := []string{"a", "b", "c", "d"}
    Arr2 := []string{"c", "e", "f", "g"}
    AddChan := make(chan string)
    DelChan := make(chan string)

    var wg sync.WaitGroup
    wg.Add(2)
    go FindinFirst(&Arr1, &Arr2, AddChan, &wg)
    go FindinSecond(&Arr2, &Arr1, DelChan, &wg)
    counter := 0
    for {
        select {
        case Add, ok := <-AddChan:
            if ok == true {
               fmt.Println(Add)
            } else {
                counter += 1
            }
        case Del, ok := <-DelChan:
            if ok == true {
                fmt.Println(Del)
            } else {
                counter += 1
            }
        }

        //if both the channels are closed, we are good, hence exit
        if counter == 2 {
            break
        }
    }
}

【讨论】：