我对大猩猩程序没有结束有问题,尽管有一个WaitGroup.在附加的代码中,您可以看到Heap的置换算法的实现.我想要加快速度,所以我 for each 可能的第一个数字创建了一个Goroutine,从而将每个Goroutine的排列减少到(n-1)!
个.总而言之,我应该还有n!
个排列(n*(n-1)! = n!
个),但我的主 routine 似乎在子 routine 结束之前退出了.然后,我try 跟踪已执行的排列.与我的看法相反,执行的排列的数量并不是恒定的,但总是比n!
低一点(对于低n
)或非常低(对于大n
).
例如,n=4
的排列每次是24,也就是4!
,因此所有的Goroutine都结束了.但如果我有一个更大的数字,如n=8
,我得到的值大约是13500
,而不是预期的40000 = 8!
.
这种行为从何而来?如何确保在主程序退出之前我的所有Goroutine都已完成?所有的帮助我们都非常感激.
package main
import (
"fmt"
"sync"
)
var wg sync.WaitGroup
var permutations int
func main() {
n := 9
wg.Add(n)
for i := 0; i < n; i++ {
var arr []int
for j := 0; j < n; j++ {
if i != j {
arr = append(arr, j+1)
}
}
go threadFunction(n-1, i+1, arr)
}
wg.Wait()
fmt.Println(permutations)
}
func threadFunction(k int, suffix int, arr []int) {
defer wg.Done()
heapPermutation(k, suffix, arr)
}
func heapPermutation(k int, prefix int, arr []int) {
if k == 1 {
arr = append(arr, prefix)
// fmt.Println(arr)
permutations++
} else {
heapPermutation(k-1, prefix, arr)
for i := 0; i < k-1; i++ {
if k%2 == 0 {
arr[i], arr[k-1] = arr[k-1], arr[i]
} else {
arr[0], arr[k-1] = arr[k-1], arr[0]
}
heapPermutation(k-1, prefix, arr)
}
}
}
(同样的行为可以很容易地实现,例如在https://go.dev/play/上,因此它非常可重现)
先谢谢你.