当前位置: > > > > golang并发添加节点到链表
golang并发添加节点到链表
来源:stackoverflow
2024-05-01 19:09:35
0浏览
收藏
从现在开始,我们要努力学习啦!今天我给大家带来《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的技术知识我们会一点点深入介绍,欢迎大家关注米云公众号,一起学习编程~
