为什么在尝试 Goroutines 后我的代码 运行 变慢了?
Why is my code running slower after trying Goroutines?
我决定尝试找出 Goroutines 和通道。我做了一个函数,它接受一个列表并将 10 添加到每个元素。然后我创建了另一个尝试合并通道和 goroutines 的函数。当我为代码计时时,它 运行 慢得多。我尝试做一些研究,但无法弄清楚任何事情。
这是我的频道代码:
package main
import ("fmt"
"time")
func addTen(channel chan int) {
channel <- 10 + <-channel
}
func listPlusTen(list []int) []int {
channel := make(chan int)
for i:= 0; i < len(list); i++ {
go addTen(channel)
channel <- list[i]
list[i] = <-channel
}
return list
}
func main(){
var size int
list := make([]int, 0)
fmt.Print("Enter the list size: ")
fmt.Scanf("%d", &size)
for i:=0; i <= size; i++ {
list = append(list, i)
}
start := time.Now()
list = listPlusTen(list)
end := time.Now()
fmt.Println(end.Sub(start))
}
您正在向基准算法添加大量同步开销。你有 len(list) goroutines,都在等待从一个公共频道读取。当您写入通道时,调度程序会选择其中一个 goroutine,该 goroutine 加 10,然后写入通道,这会再次启用主 goroutine。如果不真正测量就很难推测,但如果你将 goroutine 创建移到 for 循环之外,那么你将只有一个 goroutine,从而减少调度程序的开销。但是,与基线算法相比,这会更慢,因为每个操作都涉及两次同步和两次上下文切换,这比算法本身花费更多。
我在 go routines 方面也有类似的经历,我使用相同的函数发出了 20 个 http 请求。
在简单循环中调用函数比使用等待组快得多
我决定尝试找出 Goroutines 和通道。我做了一个函数,它接受一个列表并将 10 添加到每个元素。然后我创建了另一个尝试合并通道和 goroutines 的函数。当我为代码计时时,它 运行 慢得多。我尝试做一些研究,但无法弄清楚任何事情。
这是我的频道代码:
package main
import ("fmt"
"time")
func addTen(channel chan int) {
channel <- 10 + <-channel
}
func listPlusTen(list []int) []int {
channel := make(chan int)
for i:= 0; i < len(list); i++ {
go addTen(channel)
channel <- list[i]
list[i] = <-channel
}
return list
}
func main(){
var size int
list := make([]int, 0)
fmt.Print("Enter the list size: ")
fmt.Scanf("%d", &size)
for i:=0; i <= size; i++ {
list = append(list, i)
}
start := time.Now()
list = listPlusTen(list)
end := time.Now()
fmt.Println(end.Sub(start))
}
您正在向基准算法添加大量同步开销。你有 len(list) goroutines,都在等待从一个公共频道读取。当您写入通道时,调度程序会选择其中一个 goroutine,该 goroutine 加 10,然后写入通道,这会再次启用主 goroutine。如果不真正测量就很难推测,但如果你将 goroutine 创建移到 for 循环之外,那么你将只有一个 goroutine,从而减少调度程序的开销。但是,与基线算法相比,这会更慢,因为每个操作都涉及两次同步和两次上下文切换,这比算法本身花费更多。
我在 go routines 方面也有类似的经历,我使用相同的函数发出了 20 个 http 请求。
在简单循环中调用函数比使用等待组快得多