package mainimport ( "fmt" "os" "os/exec" "bufio" "reflect")func runTheCommand(ch chan<- string, cmD string) { ouT,_ := exec.Command("sh","-c",cmD).Output() ch <- string(ouT)}// Readln returns a single line (without the ending \n) from the input buffered reader. An error is returned iff there is an error with the buffered reader.func Readln(r *bufio.Reader) (string, error) { var (isPrefix bool = true err error = nil line, ln []byte ) for isPrefix && err == nil { line, isPrefix, err = r.ReadLine() ln = append(ln, line...) } return string(ln),err}func main() { var chans = []chan string{} f, _ := os.Open("../tmpStatus.config") r := bufio.NewReader(f) cmD, e := Readln(r) for e == nil { ch := make(chan string) chans = append(chans, ch) go runTheCommand(ch,cmD) cmD,e = Readln(r) } cases := make([]reflect.SelectCase, len(chans)) for i, ch := range chans { cases[i] = reflect.SelectCase{Dir: reflect.SelectRecv, Chan: reflect.ValueOf(ch)} } remaining := len(cases) for remaining > 0 { chosen, value, ok := reflect.Select(cases) if !ok { cases[chosen].Chan = reflect.ValueOf(nil) remaining -= 1 continue } fmt.Printf("%s", value.String()) } } 此代码正确打印出从通道接收到的所有值。但最终它退出并出现以下错误:致命错误:所有 goroutine 都处于睡眠状态 - 死锁!goroutine 1 [选择]:reflect.rselect(0xc200283480, 0x22, 0x22, 0xffffffffffffffff, 0x0, ...) /usr/local/go/src/pkg/runtime/chan.c:1212 +0x10d reflect.Select(0x68000000) 0x22, 0x22, 0x1, 0x0, ...) /usr/local/go/src/pkg/reflect/value.go:1957 +0x1fb我是 GO 的新手。我提到了谷歌,并以某种方式设法编写了一个工作代码。我不完全理解这个脚本是如何工作的,尤其是反射包命令。我的目的是并行执行 ../tmpStatus.config 文件中列出的 unix 命令并打印出结果。我对 GO 提供的并发功能感到兴奋,因此决定尝试一下。现在它打印结果如此之快。直到现在,我都是在 python 中一一做到这一点的。我在安装到自定义位置的 go 版本 go1.1.2 linux/amd64 中运行此脚本。知道为什么会发生僵局吗?
1 回答
- 1 回答
- 0 关注
- 224 浏览
添加回答
举报
0/150
提交
取消