通过 for 循环的 goroutine 通道

Question

我的main函数从文件中读取 json，将其解组为结构体，将其转换为另一种结构体类型并通过标准输出输出格式化的 JSON。

我正在尝试实现 goroutines 和通道来为我的for循环添加并发性。

func main() {

    muvMap := map[string]string{"male": "M", "female": "F"}

    fileA, err := os.Open("serviceAfileultimate.json")

    if err != nil {

        panic(err)

    }

    defer fileA.Close()

    data := make([]byte, 10000)

    count, err := fileA.Read(data)

    if err != nil {

        panic(err)

    }

    dataBytes := data[:count]

    var servicesA ServiceA

    json.Unmarshal(dataBytes, &servicesA)

    var servicesB = make([]ServiceB, servicesA.Count)

    goChannels := make(chan ServiceB, servicesA.Count)

    for i := 0; i < servicesA.Count; i++ {

        go func() {

            reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Address").SetString(Merge(&servicesA.Users[i].Location))

            reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Date_Of_Birth").SetString(dateCopyTransform(servicesA.Users[i].Dob))

            reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Email").SetString(servicesA.Users[i].Email)

            reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Fullname").SetString(Merge(&servicesA.Users[i].Name))

            reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Gender").SetString(muvMap[servicesA.Users[i].Gender])

            reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Phone").SetString(servicesA.Users[i].Cell)

            reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Username").SetString(servicesA.Users[i].Username)

            goChannels <- servicesB[i]

        }()

    }

    for index := range goChannels {

        json.NewEncoder(os.Stdout).Encode(index)

    }

}

它编译但返回如下消息：

goroutine 1 [chan receive]: main.main() C://.....go.94 +0x55b.

Answer 1

您正在打印频道信息，而不是它包含的数据。你不想要一个循环，你只想接收然后打印。&nbsp; &nbsp;json := <-index&nbsp; &nbsp;json.NewEncoder(os.Stdout).Encode(json)现在我需要指出的是，该代码不会阻塞。如果您想继续阅读直到所有工作完成，您需要某种锁定/协调机制。你会经常看到类似的东西for {&nbsp; &nbsp;select {&nbsp; &nbsp; &nbsp; &nbsp; case json := <-jsonChannel:&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // do stuff&nbsp; &nbsp; &nbsp; &nbsp; case <-abort:&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // get out of here&nbsp;&nbsp; &nbsp;}}去处理那个。此外，仅供参考，您正在使用默认容量（意味着它是一个缓冲的频道）初始化您的频道，这很奇怪。我建议查看有关该主题的一些教程，因为总体而言，您的设计需要一些工作，实际上是对非并发实现的改进。最后，您可以找到一些库来为您抽象这些工作，大多数人可能会建议您这样做。这是一个例子；https://github.com/lytics/squaredance