java - Broken Pipe Java 程序在外部 C 程序 stdin 中写入并从 stdout 读取

Question

我正在使用以下java代码在C程序的stdin中写入，该程序基本上从stdin读取，将A_A_A添加到行尾，并将其写回java程序从中读取的stdout中并抛出stdout

BufferedWriter b_stdout = new BufferedWriter(new OutputStreamWriter(fuse.process.getOutputStream()));
        String strLine;
        BufferedReader br = new BufferedReader(new FileReader("/home/Desktop/data1024.dat"));
               while ((strLine=br.readLine())!=null)
                    {

                      b_stdout.newLine();               
                      b_stdout.write(strLine);
                      b_stdout.flush();
}

data1024 文件是大小为 1 MB 的文本文件。上面是一个用C程序编写的线程...以下是C程序

main() {
int rc;
int df;
int i;
char buf[32768];
rc = fcntl(fileno(stdin), F_SETFL, O_NONBLOCK);
FILE *fp;
for (i=0;i<=10000000;i++) 
{
    int rc=-1;
    memset(buf,'\0',32768);
    //rc = fread(buf,5, 1, stdin);
    rc = read(fileno(stdin),buf,32768); 
    if (rc > 0)
    {
        strcat(buf,"B_B_B_B_B_B_B_B_B");
        write(fileno(stdout),buf,strlen(buf));
        /*fp=fopen("wroteExeB","a");
        fprintf(fp,"%s",buf);
        fclose(fp);*/
        //printf("%s",buf);
    }
}

另一个 java 线程从下面这个 C 程序的标准输出中读取

public void run(){
    try{
        String strLine;
        int c;
        BufferedReader bill_stdout = new BufferedReader(new InputStreamReader(fuse.process.getInputStream()));
        BufferedWriter new_write = new BufferedWriter(new FileWriter("/homeDesktop/data89.dat"));

    while ((strLine = bill_stdout.readLine()) != null)   {
        new_write.newLine();
        new_write.write(strLine);

        System.out.println("output thread "+strLine);
        new_write.flush();
                }

现在当我运行程序时

我一直面临着 Broken:Pipe 错误

我能够将一些行写入 C 程序，因为我可以在输入程序的标准输出中看到它们。

有些行是输出线程输出的一部分，但在 C 程序中写入的输入线程在诸如 17 或 18 之类的几行之后会给出以下错误

java.io.IOException: Broken pipe

有人可以帮忙吗...我尝试使用FileWriter一次写入一个字符，而不是使用BufferedWriter，在这种情况下它可以工作并继续写入字符.

我尝试减少写入的输入行的大小...我尝试停止输入线程，这样管道可能会因已满且尚未读取数据而破裂。但没有任何作用

请帮忙。谢谢

Answer 1

我没有详细看过代码，但是C代码是否将stdin设置为非阻塞？这不会让 C 程序立即退出，从而在您尝试写入时导致管道损坏吗？