如何解决简单程序死锁,无法确定原因
我在以下代码中遇到死锁错误,但我无法确定原因。 代码的目标是递归地获取给定文件夹中所有文件的 sha256 哈希值。 (最终目标是基于hash去除重复文件,作为学习项目)
为此,它生成了一个 goroutine,该 goroutine 为每个文件生成另一个 goroutine 以获取哈希。散列存储在一个通道中,并在代码的末尾以一个简单的循环读取。
根据打印件,检查所有文件,并且 wg.Add 和 Done 似乎在正确的位置。
代码:
package main
import (
"crypto/sha256"
"fmt"
"io"
"io/fs"
"log"
"os"
"path/filepath"
"sync"
"time"
)
func get_fsha256sum(filepath string) string {
f,err := os.Open(filepath)
if err != nil {
log.Fatal(err)
}
defer f.Close()
return get_sha256sum(f)
}
func get_sha256sum(r io.Reader) string {
h := sha256.New()
if _,err := io.Copy(h,r); err != nil {
log.Fatal(err)
}
return fmt.Sprintf("%x",h.Sum(nil))
}
func main() {
start := time.Now()
ch := make(chan string,10000)
var wg sync.WaitGroup
var get_fsha256sum_wrap = func(filepath string) {
start := time.Now()
ch <- get_fsha256sum(filepath)
fmt.Printf("%f-%s\n",filepath,time.Since(start))
wg.Done()
}
var walk_func = func(filepath string,info fs.DirEntry,err error) error {
wg.Add(1)
if err != nil {
return err
}
if info.IsDir() {
return nil
}
go get_fsha256sum_wrap(filepath)
return nil
}
var over_wrap = func(root string) {
filepath.WalkDir(root,walk_func)
wg.Wait()
close(ch)
}
go over_wrap("/run/media/user/Red/pictures_master/2021/01")
for v := range ch {
fmt.Println(v)
}
fmt.Printf("%s",time.Since(start))
}
错误信息:
fatal error: all goroutines are asleep - deadlock!
goroutine 1 [chan receive]:
main.main()
/home/user/go_phockup/main.go:66 +0x273
goroutine 18 [semacquire]:
sync.runtime_Semacquire(0xc0000b8018)
/usr/local/go/src/runtime/sema.go:56 +0x45
sync.(*WaitGroup).Wait(0xc0000b8010)
/usr/local/go/src/sync/waitgroup.go:130 +0x65
main.main.func3(0x4e3d3f,0x2b)
/home/go_phockup/main.go:62 +0x5e
created by main.main
/home/user/go_phockup/main.go:65 +0x1bd
exit status 2
知道出了什么问题吗?
解决方法
您的等待组正在等待比您创建的更多的 goroutine。 walk_func 添加到 wg
,但可能会在不创建新 goroutine 的情况下返回。替换为:
var walk_func = func(filepath string,info fs.DirEntry,err error) error{
if err != nil {
return err
}
if info.IsDir() {
return nil
}
wg.Add(1)
go get_fsha256sum_wrap(filepath)
return nil
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。