gpt4 book ai didi

使用 slice 类型的输入和输出 channel 去并发工作例程

转载 作者:数据小太阳 更新时间:2023-10-29 03:14:13 25 4
gpt4 key购买 nike

我对 Go 语言比较陌生。尽管我不希望如此,但我可能会用一个愚蠢的问题来打扰你。我提前道歉,以防万一......

这是我的示例:我定义了一个从 main() 调用的 worker() 函数作为一组并发 Go 例程。输入和输出数据通过 slice 类型 []int 的输入和输出 channel 提供。在一种情况下,一切都按预期工作,在另一种情况下,结果是错误的。查看代码中的注释和代码下方的程序输出。

老实说,我看不出这两种代码变体之间的实际区别。我在这里错过了什么?感谢您的任何建议!

package main

import "fmt"
import "runtime"

func worker(x_ch <-chan []int, y_ch chan<- []int, wid int) {

for x := range x_ch {
y := x
fmt.Println(" worker", wid, "x:", x)
fmt.Println(" worker", wid, "y:", y)
y_ch <- y
}
}

func main() {

n_workers := runtime.NumCPU()
n_len := 4
n_jobs := 4
x := make([]int, n_len)
x_ch := make(chan []int, 10)
y_ch := make(chan []int, 10)

for j := 0; j < n_workers; j++ { go worker(x_ch, y_ch, j) }

for k := 0; k < n_jobs; k++ {

// variant 1: works!
x = []int{k, k, k, k}

// variant 2: doesn't work!
// for i := range x { x[i] = k }

fmt.Println("main x:", k, x)
x_ch <- x
}

close(x_ch)

for i := 0; i < n_jobs; i++ {
z := <- y_ch
fmt.Println(" main y:", i, z)
}
}

正确的输出(变体 1):

main x: 0 [0 0 0 0]
main x: 1 [1 1 1 1]
main x: 2 [2 2 2 2]
main x: 3 [3 3 3 3]
worker 3 x: [3 3 3 3]
worker 3 y: [3 3 3 3]
worker 2 x: [2 2 2 2]
worker 2 y: [2 2 2 2]
worker 1 x: [0 0 0 0]
worker 1 y: [0 0 0 0]
worker 0 x: [1 1 1 1]
worker 0 y: [1 1 1 1]
main y: 0 [3 3 3 3]
main y: 1 [2 2 2 2]
main y: 2 [0 0 0 0]
main y: 3 [1 1 1 1]

错误的输出(变体 2):

main x: 0 [0 0 0 0]
main x: 1 [1 1 1 1]
main x: 2 [2 2 2 2]
main x: 3 [3 3 3 3]
worker 3 x: [3 3 3 3]
worker 3 y: [3 3 3 3]
main y: 0 [3 3 3 3]
worker 0 x: [2 2 2 2]
worker 0 y: [3 3 3 3]
main y: 1 [3 3 3 3]
worker 1 x: [1 1 1 1]
worker 1 y: [3 3 3 3]
main y: 2 [3 3 3 3]
worker 2 x: [3 3 3 3]
worker 2 y: [3 3 3 3]
main y: 3 [3 3 3 3]

最佳答案

不同之处在于,在变体 1 中,您每次都发送不同的 slice ,而在变体 2 中,您每次都发送相同的 slice (在 for 循环之上创建的 slice ).在不创建新 slice 的情况下,您只是将同一 slice 的元素设置为不同的值,因此 goroutine 在查看 slice 时会看到 slice 中恰好有任何值。在变体 2 中,main 将始终看到 [3 3 3 3],因为这是循环 4 次后的最终值。 slice 对象的值包含对底层元素的引用,而不是元素本身。 slice 有很好的解释here .

关于使用 slice 类型的输入和输出 channel 去并发工作例程,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41784439/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com