Golang并发死锁

Question

谁能帮我确定为什么在我正在编写的 Go 代码末尾出现死锁错误？该程序实际上运行正常，但出现死锁错误。我是编写并发代码的新手，因此非常感谢任何帮助。我省略了一些我知道不是问题的行，只是为了让它更快阅读。func MoveWorksheets(worksheetList []string) {var wg sync.WaitGroupfor _, worksheet := range worksheetList {    wg.Add(1)    go MoveFile(src, dst, wg)    }    wg.Wait()}func MoveFile(src, dst string, wg sync.WaitGroup) (err error) {    defer wg.Done()    sfi, err := os.Stat(src)    if err != nil {        return    }    if !sfi.Mode().IsRegular() {        // cannot copy non-regular files (e.g., directories,        // symlinks, devices, etc.)        return fmt.Errorf("CopyFile: non-regular source file %s (%q)", sfi.Name(), sfi.Mode().String())    }    dfi, err := os.Stat(dst)    if err != nil {        if !os.IsNotExist(err) {            return        }    } else {        if !(dfi.Mode().IsRegular()) {            return fmt.Errorf("CopyFile: non-regular destination file %s (%q)", dfi.Name(), dfi.Mode().String())        }        if os.SameFile(sfi, dfi) {            return        }    }    /*if err = os.Link(src, dst); err == nil {        return    }*/    err = MoveFileContents(src, dst)    return}func MoveFileContents(src, dst string) (err error) {    merr := os.Rename(src, dst)    if merr != nil {        log.Fatal(merr)    }    return}

Answer 1

MoveFile正在获取 的副本wg，因此您在不同的 s上调用Wait()和。尝试将其作为指针传递。Done()WaitGroup

Answer 2

尝试传递wg变量的引用，在您的代码MoveFile函数中获取它自己的 WaitGroup 副本。这就是它造成死锁的原因。

   func MoveWorksheets(worksheetList []string) {

        var wg sync.WaitGroup

        for _, worksheet := range worksheetList {

          wg.Add(1)

          go MoveFile(src, dst, &wg)

        }

        wg.Wait()

    }

    func MoveFile(src, dst string, wg *sync.WaitGroup) (err error) {

        defer wg.Done()

        sfi, err := os.Stat(src)

        if err != nil {

            return

        }

        if !sfi.Mode().IsRegular() {

            // cannot copy non-regular files (e.g., directories,

            // symlinks, devices, etc.)

            return fmt.Errorf("CopyFile: non-regular source file %s (%q)", sfi.Name(), sfi.Mode().String())

        }

        dfi, err := os.Stat(dst)

        if err != nil {

            if !os.IsNotExist(err) {

                return

            }

        } else {

            if !(dfi.Mode().IsRegular()) {

                return fmt.Errorf("CopyFile: non-regular destination file %s (%q)", dfi.Name(), dfi.Mode().String())

            }

            if os.SameFile(sfi, dfi) {

                return

            }

        }

        /*if err = os.Link(src, dst); err == nil {

            return

        }*/

        err = MoveFileContents(src, dst)

        return

    }

    func MoveFileContents(src, dst string) (err error) {

        merr := os.Rename(src, dst)

        if merr != nil {

            log.Fatal(merr)

        }

        return

    }