我有一个 child_process 需要 100 秒才能运行。“主”程序将产生 child_process 并等待它完成,或者提前终止它。
这是主程序的代码片段。它fmt.Println
是进度并stdin
使用 goroutine 检查它。一旦收到“终止”,主进程将消息传递给子进程以中断它。
//master program
message := make(chan string)
go check_input(message)
child_process := exec.Command("child_process")
child_stdin := child_process.StdinPipe()
child_process.Start() //takes 100 sec to finish
loop:
for i=:1;i<=100;i++ {
select {
case <- message:
//end child process
child_stdin.Write([]byte("terminate\n"))
break loop
case <- time.After(1*time.Second):
fmt.Println(strconv.ItoA(i) + " % Complete") // update progress bar
}
child_process.Wait() //wait for child_process to be interrupted or finish
主程序和子进程都使用“check_input”函数。它从标准输入接收“终止”消息。
//check_input function
func check_input(msg chan string){
reader := bufio.NewReader(os.Stdin)
for {
line, err := reader.ReadString('\n')
if err != nil {
// You may check here if err == io.EOF
break
}
if strings.TrimSpace(line) == "terminate" {
msg <- "terminate"
}
}
}
它目前适用于 goroutine 和 chan。
我的问题是是否有更好的方法来发出信号/杀死/中断 child_process。