碎管道Java程序在外部C程序stdin中写入，并从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();
}

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);
    }
}

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();
                }

java.io.IOException: Broken pipe