我正在使用Golang启动一个进程并监视输出.这一过程将运行很长时间,我需要能够发送信号来结束它.
我有以下代码,它在大多数时间运行良好.但是,由于某些原因,该进程可能没有输出,并且For循环将被Scan()
方法阻塞,并且无法从processFinishChan
接收.
有没有简单的方法来设置Scan()
方法的超时时间?我try 了一个在另一个Goroutine中运行Scan()
的解决方案,并使用另一个SELECT从新的Goroutine和一个超时通道接收,但考虑到外部for
循环,是否会有越来越多的Goroutine被Scan
阻塞?
// code that start the process...
scanner := bufio.NewScanner(stdout)
for {
select {
case <-processFinishChan: // send to this channel to terminate the process
log.Println("Killing Process")
err := cmdObject.Process.Kill()
if err != nil {
log.Printf("Error Killing: %v", err)
} else {
return
}
default:
// default case, read the output of process and send to user.
if !scanner.Scan() && scanner.Err() == nil {
// reach EOF
return
}
m := scanner.Bytes()
WSOutChanHolder.mu.Lock()
for _, ch := range WSOutChanHolder.data {
ch <- m
}
WSOutChanHolder.mu.Unlock()
}
}