golang死锁错误，有waitgroup但没有通道

学习Golang要努力，但是不要急！今天的这篇文章《golang死锁错误，有waitgroup但没有通道》将会介绍到等等知识点，如果你想深入学习Golang，可以关注我！我会持续更新相关文章的，希望对大家都能有所帮助！

我是新来的。我有一个关于矩阵及其运算的项目。我应该在我的乘法函数中使用 goroutine。（同时免责声明：这不是我的代码，它是一个小组项目，我应该将 goroutine 添加到函数中） 我到处搜索并在不同的网站上看到了这种方式（我使用的方式）。但是我得到了一个致命错误：所有的 goroutine 都睡着了。死锁！ 或者代码运行时间太长。

    func (m matrix) multiply(n matrix) matrix {
        var ans  = buildzeromatrix(len(m), len(n[0]))
        var wg sync.waitgroup
        wg.add(len(m)*len(n[0])*len(n))
        for i := 0; i < len(m); i++ {
            for j := 0; j < len(n[0]); j++ {
                for k := 0; k < len(n); k++ {
                    wg.add(1)
                    go func(j int, i int, k int) {
                        ans[i][j] += m[i][k] * n[k][j]
                        defer wg.done()
                    }(j, i, k)
                }
            }
        }
        go func(){
            wg.wait()

        }()
        return ans
    }

这是乘法函数。

type matrix [][]float64

这是矩阵。

    func BuildZeroMatrix(Row int, Col int) Matrix {
        var temp [][]float64
        for i := 0; i < Row; i++ {
            var tmp []float64
            for j := 0; j < Col; j++ {
                tmp = append(tmp, 0)
            }
            temp = append(temp, tmp)
        }
        M, _ := BuildMatrix(Row, Col, temp)
        return M
    }

这是 buildzeromatrix 函数。 我给函数 2 500*500 矩阵，运行大约需要 10 秒，否则会出现致命错误。 我发现的关于这个问题的每个帖子都有频道，他们的问题出在频道上。但是我没有。

正确答案

只是指出此片段中的错误。请检查内嵌评论。

func (m matrix) multiply(n matrix) matrix {
    var ans  = buildzeromatrix(len(m), len(n[0]))
    var wg sync.waitgroup
    wg.add(len(m)*len(n[0])*len(n)) // this is unnecessary. you are already adding the goroutine inside the k loop.
    for i := 0; i < len(m); i++ {
        for j := 0; j < len(n[0]); j++ {
            for k := 0; k < len(n); k++ {
                wg.add(1)
                go func(j int, i int, k int) {
                    ans[i][j] += m[i][k] * n[k][j] // this is data race area. multiple goroutines will try to write to the same address. you will need a lock here.
                    defer wg.done()
                }(j, i, k)
            }
        }
    }
    go func(){
        wg.wait() // wait()ing for goroutines to be completed should not be done inside a goroutine. because here you don't wait for this goroutine to be done.
    }()
    return ans
}

更新：请检查示例代码

package main

import (
    "fmt"
    "sync"
)

type Matrix [][]float64

func (M Matrix) Multiply(N Matrix) Matrix {
    var ans = BuildZeroMatrix(len(M), len(N[0]))
    var wg sync.WaitGroup
    var mx sync.Mutex
    for i := 0; i < len(M); i++ {
        for j := 0; j < len(N[0]); j++ {
            for k := 0; k < len(N); k++ {
                wg.Add(1)
                go func(j int, i int, k int) {
                    defer wg.Done()
                    mx.Lock()
                    ans[i][j] += M[i][k] * N[k][j]
                    mx.Unlock()
                }(j, i, k)
            }
        }
    }
    wg.Wait()
    return ans
}
func BuildZeroMatrix(Row int, Col int) Matrix {
    var temp [][]float64
    for i := 0; i < Row; i++ {
        var tmp []float64
        for j := 0; j < Col; j++ {
            tmp = append(tmp, 0)
        }
        temp = append(temp, tmp)
    }
    return temp
}

func main() {
    var m, n Matrix

    // T1:
    m = Matrix{[]float64{1, 1, 1}, []float64{1, 1, 1}, []float64{1, 1, 1}}
    n = Matrix{[]float64{1, 1, 1}, []float64{1, 1, 1}, []float64{1, 1, 1}}
    fmt.Printf("%v", m.Multiply(n))

    // T2:
    m = Matrix{[]float64{1, 1, 1}, []float64{1, 1, 1}, []float64{1, 1, 1}}
    n = Matrix{[]float64{1, 1}, []float64{1, 1}, []float64{1, 1}}
    fmt.Printf("\n%v", m.Multiply(n))
}

理论要掌握，实操不能落！以上关于《golang死锁错误，有waitgroup但没有通道》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！