Golang並行デッドロック

Question

私が書いているこのGoコードの終わりにデッドロックエラーが発生する理由を知るには誰も助けてくれますか？プログラムは実際には正常に動作しますが、デッドロックエラーが発生します。私はコンカレントコードを書くのが初めてで、どんな助けでも大歓迎です。私は読んですぐにそれを問題にしないと分かっている行を省略しました。

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 
} 

Answer 1

MoveFilewgのコピーを取得しているので、あなたは別のWaitGroupの上Wait()とDone()を呼んでいます。ポインタとして渡してみてください。

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 
    }