尽管存在WaitGroup,Goroutine似乎会被中断[关闭]

2vuwiymt  于 2023-04-18  发布在  Go
关注(0)|答案(1)|浏览(106)

**已关闭。**此问题为not reproducible or was caused by typos。当前不接受答案。

这个问题是由一个错字或一个无法再复制的问题引起的。虽然类似的问题可能是on-topic在这里,但这个问题的解决方式不太可能帮助未来的读者。
5天前关闭。
这篇文章是编辑并提交审查3天前.
Improve this question
我有一个问题,尽管有一个WaitGroup,但goroutine仍然不能结束。在后面的代码中,你可以看到Heap的排列算法的实现。我想加快它的速度,所以我为每个可能的第一个数字创建了一个goroutine,从而将每个goroutine的排列减少到(n-1)!。总的来说,我应该仍然有n!排列(n*(n-1)! = n!),但是我的主程序似乎在子程序完成之前就退出了。然后我试着跟踪执行的排列。与我的信念相反,执行的排列数不是恒定的,但在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)
        }
    }
}

(The例如,在https://go.dev/play/上可以容易地实现相同的行为,因此它是非常可再现的。

pqwbnv8z

pqwbnv8z1#

在你的代码中,goroutines同时访问permutations变量。当你增加n的值时,工作负载会增加,这会导致意外的结果。
你可以使用一个mutex,它将确保只有一个goroutine可以访问permutations

package main

import (
    "fmt"
    "sync"
)

var wg sync.WaitGroup
var permutations int
var permutationsMutex sync.Mutex

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)
        permutationsMutex.Lock()
        permutations++
        permutationsMutex.Unlock()
    } 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)
        }
    }
}

相关问题