В Windows: получите небуферизованный стандартный вывод из программы на C в Java-программу InputStream [Теперь с минимальным примером!]

РЕШИТЬ:

HovecraftFullOfEels нашел мою ошибку. См. Комментарии к его ответу ниже. Я вызывал run() в объекте Thread, когда мне приходилось запускать start(). В моей первоначальной программе это означало, что он заблокирован на stderr до тех пор, пока программа не завершится, а затем сразу выйдет stdout.

ОБНОВИТЬ:

В соответствии с просьбой я привел минимальный пример. Здесь производитель:

package producer;

public class Producer {

    public static void main(String[] args) throws InterruptedException {
        for (int i=0; i<10; i++) {
            System.out.println(i);
            System.out.flush();
            Thread.sleep(1000);
        }
    }    
}

Здесь потребитель:

package consumer;

import java.io.IOException;
import java.io.InputStream;

public class Consumer {
    static class Dumper extends Thread {
        InputStream r;
        boolean print;

        Dumper(InputStream r, boolean print) {
            this.r = r;
            this.print = print;
        }

        @Override
        public void run() {
            int c;
            try {
                while ((c = r.read()) != -1) {
                    if (print) System.out.print((char)c);
                }
                r.close();
            } catch (IOException ex) {}
        }
    }

    public static void main(String[] args) throws Exception {
        Process p = Runtime.getRuntime().exec("java -jar C:\\Users\\millerti\\Documents\\NetBeansProjects\\Producer\\dist\\Producer.jar");
        new Dumper(p.getErrorStream(), false).run();
        new Dumper(p.getInputStream(), true).run();
        p.waitFor();
    }
}

Ожидаемое поведение: поскольку производитель сбрасывает свою продукцию, а потребитель полностью не загружается, потребитель должен получать продукцию производителя в режиме реального времени.

Наблюдаемое поведение: потребитель получает продукцию производителя сразу же, только когда производитель закончил.

Оригинальное сообщение:

Я работаю с другим разработчиком в приложении Windows. Она написала программу на C (которую мы можем изменить), которая выполняет преобразование мультимедиа и печатает сообщения о проделанной работе (в процентах) в stdout. Я пишу графический интерфейс в Java, и я хотел бы, чтобы моя программа захватила эти сообщения и обновила элемент графического интерфейса.

Соответствующий программный код C выглядит следующим образом:

printf ("progress_msg: %d%%\n", currentProgress);
fflush(stdout);

В программе Java я использую Runtime.getRuntime().exec() для запуска программы C и захвата необработанных объектов InputStream для программных stdout и stderr. (Stderr просто отбрасывается другим потоком.) Я разбираю поток stdout, ища эти сообщения (ну, я был, используя BufferedReader, но прямо сейчас, я пытаюсь отладить это, m, разговаривая напрямую с источником байта нижнего уровня InputStream.)

Проблема в том, что, хотя на стороне Java нет (но я не знаю) буферизации на стороне Java и там есть fflush в программе C, текст stdout появляется сразу, только когда заканчивается программа C. Это не похоже на то, когда я запускаю его из командной строки, где сообщения появляются постепенно, как ожидалось.

Так ясно, что происходит буферизация. Является ли средство Process в Java делать некоторую буферизацию, о которой я не знаю? Если да, есть ли способ отключить его? Неужели fflush(stdout) в Windows не работает ожидаемым образом? Каков правильный эквивалент Windows?

Благодарю.

Примечание. Я нашел два связанных stackoverflows, но они не отвечают на этот вопрос. В частности, мы МОЖЕМ модифицировать программу C, нет буферизации строк, и мы делаем правильный флеш (насколько нам известно). См. " Я хочу, чтобы в реальном времени выводился мой Runtime.getRuntime(). Exec() и Unbuffered subprocess stdout в Windows.