使用 GO 写入 C 程序但 C 程序不会在 scanf() 处停止
Writing to C program using GO but C program doesn't stop at scanf()
在这些片段中,go 程序尝试写入 C 程序的标准输入。问题是c程序在go循环结束后开始无限循环。
main.c
#include <stdio.h>
#include <stdlib.h>
int main(){
int age;
char name[8];
for(;;)
{
scanf(" %s : %d\n",&name, &age);
printf("%s : %d\n",name, age);
}
return 0;
}
run/main.go
func main() {
proc := exec.Command("../main")
stdin, err := proc.StdinPipe()
if err != nil {
fmt.Println(err)
}
defer stdin.Close()
proc.Stdout = os.Stdout
proc.Stderr = os.Stderr
fmt.Println("START")
if err = proc.Start(); err != nil {
log.Fatal("An error occured: ", err)
}
for i := 0; i < 500; i++ {
io.WriteString(stdin, fmt.Sprintf("hello : %d\n", i))
//How to wait here and read from printf()?
}
//proc.Process.Kill() Here proc gets killed too fast
fmt.Println("END")
}
终止时,进程不会完成它的输出
输出
START
END
hello : 497
hello : 498
hello : 499
hello : 499
预期输出
START
....
hello : 497
hello : 498
hello : 499
END
在阅读评论和更多搜索后,我已经解决了。
在 C 程序中,我从 scanf() 中删除了 \n 并在 printf 之后添加了 fflush(stdout)。
根据这个 我把它们改成了这些:
int main(){
int age;
char name[8];
int ret;
for(;;)
{
ret= scanf("%s : %d",&name, &age);
if (ret == -1) {
break;
}
printf("%s : %d\n",name, age);
fflush(stdout);
}
return 0;
}
func main(){
proc := exec.Command("../main")
stdin, err := proc.StdinPipe()
if err != nil {
fmt.Println(err)
}
reader, err := proc.StdoutPipe()
if err != nil {
fmt.Println(err)
return
}
scanner := bufio.NewScanner(reader)
resp := make(chan string)
go func() {
for scanner.Scan() {
resp <- scanner.Text()
}
}()
err = proc.Start()
if err != nil {
fmt.Fprintln(err)
return
}
fmt.Println("START")
for i := 0; i < 500; i++ {
io.WriteString(stdin, fmt.Sprintf("hello : %d\n", i))
v := <-resp
print(v+"\n")
}
err = proc.Process.Kill()
if err != nil {
fmt.Fprintln(err)
return
}
fmt.Println("END")
}
在这些片段中,go 程序尝试写入 C 程序的标准输入。问题是c程序在go循环结束后开始无限循环。
main.c
#include <stdio.h>
#include <stdlib.h>
int main(){
int age;
char name[8];
for(;;)
{
scanf(" %s : %d\n",&name, &age);
printf("%s : %d\n",name, age);
}
return 0;
}
run/main.go
func main() {
proc := exec.Command("../main")
stdin, err := proc.StdinPipe()
if err != nil {
fmt.Println(err)
}
defer stdin.Close()
proc.Stdout = os.Stdout
proc.Stderr = os.Stderr
fmt.Println("START")
if err = proc.Start(); err != nil {
log.Fatal("An error occured: ", err)
}
for i := 0; i < 500; i++ {
io.WriteString(stdin, fmt.Sprintf("hello : %d\n", i))
//How to wait here and read from printf()?
}
//proc.Process.Kill() Here proc gets killed too fast
fmt.Println("END")
}
终止时,进程不会完成它的输出
输出
START
END
hello : 497
hello : 498
hello : 499
hello : 499
预期输出
START
....
hello : 497
hello : 498
hello : 499
END
在阅读评论和更多搜索后,我已经解决了。
在 C 程序中,我从 scanf() 中删除了 \n 并在 printf 之后添加了 fflush(stdout)。
根据这个
int main(){
int age;
char name[8];
int ret;
for(;;)
{
ret= scanf("%s : %d",&name, &age);
if (ret == -1) {
break;
}
printf("%s : %d\n",name, age);
fflush(stdout);
}
return 0;
}
func main(){
proc := exec.Command("../main")
stdin, err := proc.StdinPipe()
if err != nil {
fmt.Println(err)
}
reader, err := proc.StdoutPipe()
if err != nil {
fmt.Println(err)
return
}
scanner := bufio.NewScanner(reader)
resp := make(chan string)
go func() {
for scanner.Scan() {
resp <- scanner.Text()
}
}()
err = proc.Start()
if err != nil {
fmt.Fprintln(err)
return
}
fmt.Println("START")
for i := 0; i < 500; i++ {
io.WriteString(stdin, fmt.Sprintf("hello : %d\n", i))
v := <-resp
print(v+"\n")
}
err = proc.Process.Kill()
if err != nil {
fmt.Fprintln(err)
return
}
fmt.Println("END")
}