golang并发添加节点到链表

从现在开始，我们要努力学习啦！今天我给大家带来《golang并发添加节点到链表》，感兴趣的朋友请继续看下去吧！下文中的内容我们主要会涉及到等等知识点，如果在阅读本文过程中有遇到不清楚的地方，欢迎留言呀！我们一起讨论，一起学习！

我正在尝试使用通道和 goroutine 同时将节点添加到链表中。然而，我似乎做错了什么。这是我到目前为止所写的内容。

目前，我的打印功能只是重复第 8 个节点。这似乎适用于其他链表，所以我不完全理解这个问题。任何帮助都会很棒。这是我写的代码

func makeNodes(ctx context.Context, wg *sync.WaitGroup, ch chan Node) {
    defer wg.Done()
    for i := 0; i < 9; i++ {
        tmp := Node{Data: i, Next: nil}
        ch <- tmp
    }
    <-ctx.Done()
    return
}

type Node struct {
    Data int
    Next *Node
}

type List struct {
    Head   *Node
    Length int
    Last   *Node
}

func (l *List) addToEnd(n *Node) {
    if l.Head == nil {
        l.Head = n
        l.Last = n
        l.Length++
        return
    }
    tmp := l.Last
    tmp.Next = n
    l.Last = n
    l.Length++
}

func (l List) print() {
    tmp := l.Head
    for tmp != nil {
        fmt.Println(tmp)
        tmp = tmp.Next
    }
    fmt.Println("\n")
}

func main() {
    cha := make(chan Node)
    defer close(cha)

    ctx := context.Background()
    ctx, cancel := context.WithCancel(ctx)
    var wg sync.WaitGroup

    wg.Add(1)
    list := List{nil, 0, nil}
    go makeNodes(ctx, &wg, cha)

    go func() {
        for j := range cha {
            list.addToEnd(&j)
        }
    }()

    cancel()
    wg.Wait()

    list.print()
}

正确答案

该程序分配单个结构（for j:= range 循环中的 j），并用从通道读取的内容重复覆盖它。

这会导致同一变量（j，位于固定内存位置）被多次添加到列表中。

考虑将通道修改为指针通道。

在main()中

cha := make(chan *node)

然后对于makenodes() 每次创建新节点（通过 node{}）时，都会将一个新节点指针放入通道中。

func makenodes(ctx context.context, wg *sync.waitgroup, ch chan *node) {
    defer wg.done()
    for i := 0; i < 9; i++ {
        tmp := node{data: i, next: nil}
        ch <- &tmp
    }
    <-ctx.done()
    return
}

以下内容现在将正确地将每个唯一的节点指针添加到列表中。

go func() {
    for j := range cha {
        list.addToEnd(j)
    }
}()

此外，您可能会发现并非所有实体都会进入列表或从通道中读取。您同步生产者 (makenodes()) 和消耗 (for j:= range) 的方法需要工作。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~