在两个golang goroutine之间传递结构

golang学习网今天将给大家带来《在两个golang goroutine之间传递结构》，感兴趣的朋友请继续看下去吧！以下内容将会涉及到等等知识点，如果你是正在学习Golang或者已经是大佬级别了，都非常欢迎也希望大家都能给我建议评论哈~希望能帮助到大家！

我有两个函数，我想做的是在这两个函数之外有一个通道，并让第一个函数在 go 例程中运行并更新通道，然后第二个函数应该读取通道中的项目并做其他事情。当通道中的所有项目完成时，go 例程应该正常退出

有人可以 eli5 告诉我如何让两个 go 例程从同一通道读取数据吗？这可能吗？

类似于下面的内容...

package main

import (
    "fmt"
)

type Person struct {
    index int
    name  string
    age   int
}

func UpdatePeople(psn *chan Person, grNo int) {

    for i := 0; i < 5; i++ {
        psn := Person{
            index: 1,
            name:  "Shaun",
            age:   23,
        }
        fmt.Printf("Person: %v --- GoRoutineNumber: %v\n", psn, grNo)
    }

}

func WritePeople(psn *chan Person) {

    for i := 0; i < 5; i++ {
        psn := Person{
            index: 1,
            name:  "Shaun",
            age:   23,
        }
        fmt.Println("Writing People to DB", psn)
    }

}

func main() {

    //make channel of Person struct
    psnChan := make(chan Person)

    //I have a variable length in my program so lets say it's 6 in this case

    for i := 0; i < 6; i++ {

        /// I want to start a go routine here that writes to pointer of psnChan
        go UpdatePeople(&psnChan, i)

    }

    // I then want to read in from the channel as UpdatePeople is writing to it in a separate go routine
    for {

        _, received := <-psnChan
        if received == false {
            fmt.Println("Break out of 2nd loop")
            close(psnChan)
            break
        } else {

          go    WritePeople(&psnChan)

        }

    }
    fmt.Println("Finished")
}

https://play.golang.org/p/exjf3ly0vv8

上面的死锁是我可以解释的最简单的方法，而无需粘贴大量代码。

解决方案

正如 Sergio 指出的那样，Main goroutine 正在阻塞，因为它正在等待从 psns 通道读取数据，但没有任何内容写入它。在编写 Go 时，有一个很好的建议是只编写同步函数，另一个建议是由负责创建通道的函数控制通道何时关闭。因此，我根据这些内容对您编写的内容进行了一些重组：https://play.golang.org/p/vicGN40pGVQ。该程序将慢慢找到 Person 对象，通过通道发送它们，并在运行时写入每个 Person。如果您的用例有所不同，请告诉我们:)希望有所帮助。

理论要掌握，实操不能落！以上关于《在两个golang goroutine之间传递结构》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！