go - 如何在 go 中使用 channel 填充数组

Question

我正在尝试构建一个带有 go channel 的数组。我不关心广告订单，但我只收到来自 channel 的最后一项。

package main

import (
    "fmt"
)

func AddToMap(thing string, val string, c chan map[string]string) {
    mappy := make(map[string]string)
    mappy[thing] = val
    c <- mappy
}

func main() {
    item := make([]map[string]string, 0, 10)
    list1 := []string{"foo", "bar", "baz", "blah", "barf"}
    list2 := []string{"one", "two", "three", "four", "five"}
    c := make(chan map[string]string)
    for index, val := range list1 {
    go AddToMap(val, list2[index], c)
}
    ret := <-c
    item = append(item, ret)
    fmt.Println(item)
}

我的输出是:[map[barf:five]]

Answer 1

当数据被写入其中时，您需要从 channel 中连续读取。当你完成将数据泵入 channel 后，关闭它。这是它的工作原理。

注意:AddToMap 没有作为独立的 goroutine 被调用。这可以使用 waitgroup 来完成，因为我们需要知道何时需要关闭 channel c，这将在所有 AddToMap 运行之后。

package main

import (
    "fmt"
)

func AddToMap(thing string, val string, c chan map[string]string) {
    mappy := make(map[string]string)
    mappy[thing] = val
    c <- mappy
}

func main() {
    item := make([]map[string]string, 0, 10)
    list1 := []string{"foo", "bar", "baz", "blah", "barf"}
    list2 := []string{"one", "two", "three", "four", "five"}
    c := make(chan map[string]string)
    go func(){
        for index, val := range list1 {
            AddToMap(val, list2[index], c)
        }
        close(c)
    }()
    for ret := range c {
        item = append(item, ret)
    }
    fmt.Println(item)
}