【发布时间】:2018-01-30 09:18:09
【问题描述】:
我想了解为什么这种情况会出现死锁,为什么在另一种情况下不会。
如果我关闭 goroutine 中的通道,它可以正常工作,但如果我在 WaitGroup.Wait() 之后关闭它,则会导致死锁。
package main
import (
"fmt"
"io/ioutil"
"os"
"sync"
)
var (
wg = sync.WaitGroup{}
links = make(chan string)
)
func rec_readdir(depth int, path string) {
files, _ := ioutil.ReadDir(path)
for _, f := range files {
if symlink, err := os.Readlink(path + "/" + f.Name()); err == nil {
links <- path + "/" + symlink
}
rec_readdir(depth+1, path+"/"+f.Name())
}
if depth == 0 {
wg.Done()
// close(links) // if close here ok
}
}
func main() {
wg.Add(1)
go rec_readdir(0, ".")
for slink := range links {
fmt.Println(slink)
}
wg.Wait()
close(links) // if close here deadlock
}
【问题讨论】:
标签: go concurrency deadlock