Go lang 多路复用所有 goroutine 都处于休眠状态 - 死锁

Question

我想使用多个 go 例程返回通道创建一个扇入函数，这是我的代码。

package main

import (
    "fmt"
    "math/rand"
    "sync"
    "time"
)

var wg, wg2 sync.WaitGroup

func main() {
    final := talk(boring("Joe"), boring("Ann"))
    for i := 0; i < 10; i++ {
        fmt.Println(<-final)
    }
    fmt.Println("You are both boring I'm leaving")
}

func talk(input1, input2 <-chan string) <-chan string {
    out := make(chan string)
    go func() {
        wg.Add(1)
        for {
            out <- <-input1
        }
    }()
    go func() {
        wg.Add(1)
        for {
            out <- <-input2
        }
    }()
    wg.Done()
    close(out)
    return out
}

func boring(msg string) <-chan string {
    c := make(chan string)
    for i := 0; i < 5; i++ {
        c <- fmt.Sprintf("%s%d\n", msg, i)
        time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
    }
    return c
}

但是运行上面的代码后出现错误

所有 goroutine 都处于休眠状态 - 死锁

我已尝试关闭频道，但仍然出现错误。我试图将无聊的返回频道分配给乔和安，然后将这些频道传递给多路复用的通话功能，但仍然没有成功。我是新来的，学习渠道对这个概念不太清楚。

Answer 1

你可以使用select:https://tour.golang.org/concurrency/5代替等待组

select 语句让 goroutine 等待多个通信 操作。

A select 阻塞，直到它的一个案例可以运行，然后它执行那个 案子。如果多个都准备好了，它会随机选择一个。

package main

import (
    "fmt"
    "math/rand"
    "time"
)

func main() {
    final := talk(boring("Joe"), boring("Ann"))
    for i := 0; i < 10; i++ {
        fmt.Println(<-final)
    }
    fmt.Println("You are both boring I'm leaving")
}

func talk(input1, input2 <-chan string) <-chan string {
    c := make(chan string)
    go func() {
        for {
            select {
            case s := <-input1:
                c <- s
            case s := <-input2:
                c <- s
            }
        }
    }()
    return c
}

func boring(msg string) <-chan string {
    c := make(chan string)
    go func() {
        for i := 0; i < 5; i++ {
            c <- fmt.Sprintf("%s: %d", msg, i)
            time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
        }
    }()
    return c
}

Try it on Playground

编辑：

在您给定的示例中，boring 函数不使用 goroutine 通过通道重复发送，这将永远阻塞，因为： https://tour.golang.org/concurrency/2

默认情况下，发送和接收块，直到对方准备好。 这允许 goroutines 在没有显式锁或 条件变量。

另外，wg.Done() 需要成为 goroutine 的一部分。

我通过进行上述更改使其工作：https://play.golang.org/p/YN0kfBO6iT

Answer 2

你不能自己停止一个 goroutine，我建议用类似的方式来通知 goroutine 退出：

stop := make(chan bool)
go func() {
    for {
        select {
        case <- stop:
            return
        default:
            // Do other stuff
        }
    }
}()

// Do stuff

// Quit goroutine
stop<- true