Как правильно обновлять Progressbar из цикла?

Question

[zorgrhrd]

Привет мой спаситель!

Проблема в том что Progressbar обновляется только после окончания цикла, не могу никак заставить обновится Progressbar в процессе работы, пробовал и invokeLater, и SwingWorker, и Task, ничего не выходит, обновление происходит только после завершения цикла.

Вот код метода, он вызывается из GUI потока:

private void runCommand(String... args) throws IOException {
	
                Runtime rt = Runtime.getRuntime();
                rt.exec(args);
				
                BufferedReader stdInput = new BufferedReader(new
                        InputStreamReader(proc.getInputStream()));

                BufferedReader stdError = new BufferedReader(new
                        InputStreamReader(proc.getErrorStream()));

                appendToLog("-");

                String s = null;
                try {
                    while ((s = stdInput.readLine()) != null) {
                        appendToLog(s + "\n");
					}
                } catch (IOException e) {
                    e.printStackTrace();
                }

                try {
                    while ((s = stdError.readLine()) != null) {
                            Double progress = Double.parseDouble(s.split("%")[0]) / 100;
                            progressbar.setProgress(progress));
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
			}

В месте "progressbar.setProgress(progress));", нужно обновить данные прогрес бара, в данном случае конечно он обновится только после окончания работы, т.к. основной поток занят, но странно то что даже с SwingWorker ничего не вышло. Делал SwingWorker с publish и process, ставил точки останова, publish и process срабатывали, в процессе работы цикла новые значения поступали в process, там был код обновляющий прогресс бар согласно последнего значения в чанке "progressbar.setProgress(chunk.get(chunk.size()-1)));", но сам прогресс бар все равно обновлялся только после окончания цикла, когда SwingWorker выходил в done(); и завершался.

Хотя на сколько вычитал, publish и process как раз и нужны для вывода данных в GUI поток, или я что то не верно понимаю?

Прошу помощи.

Comments

[zorgrhrd]

Уточню, progressbar в данном случае javafx.scene.control.ProgressBar

Answer 1

[zorgrhrd]

Прошу прощения, два дня бился головой о стену в попытке понять, почему оно не работает, оказывается искал не в том месте, дело в том что буфер сначала накапливался, а потом уже после того как поток закрылся, разом отдавал вывод в цикл и прогрессбар молниеносно набирал 100%. Т.е. с обновлением бара проблем нет, дело было в самом буфере, переписал метод:

private void runCmdWithProgress(String... args) throws IOException {
        Process proc = Runtime.getRuntime().exec(args);
        InputStream inputStream = proc.getErrorStream();
        InputStreamReader inputStreamReader = new InputStreamReader(inputStream);
        BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
        String s = null;

        while ((s = bufferedReader.readLine()) != null) {
                Double progress = Double.parseDouble(s.split("%")[0]) / 100;
                Platform.runLater(() -> tab_adb_progressbar.setProgress(progress));
        }
        try {
            proc.waitFor();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

Плюс к ответу Александра, да, данный метод из GUI потока нужно вызывать обязательно в отдельном, я делаю так же как у вас:

new Thread(() -> {
	                        try {
	                            runCmdWithProgress(commands);
	                            Platform.runLater(() ->  showDialogInformation(positive);
	                        } catch (IOException e) {
	                            e.printStackTrace();
	                        }
	                    }).start();

Всем спасибо!

Comments

[zorgrhrd]

Даже смешно, как я два дня мог не замечать очевидной ошибки, ведь в примере из вопроса поток уже завершал всю работу после rt.exec(args); и буфер был полон всеми строками вывода, которые потом парсились по одной в цикле буквально за долю секунды. Посыпаю голову пеплом.

Answer 2

[Александр Плотников]

Когда в твоём приложение появляется работа, которая выполняется довольно долго, как например твои циклы, это останавливает обновление UI в целом. Чтобы твой код работал его нужно запустить в отдельном потоке, а так как JavaFX не многопоточна, то операции типа setProgress(double v) должны быть возвращены обратно в главный поток приложения методом Platform.runLater().

Platform.runLater(() -> progress.setProgress( step / size ));

А использовать Swing классы для работы с JavaFX, как мне кажется, не правильно.

Comments

[zorgrhrd]

К сожалению
Platform.runLater(() -> tab_adb_progressbar.setProgress(progress));
не помогает, я уже пробовал. Изменения UI видно только после окончания всего цикла.

[Александр Плотников]

Вот пример, в отдельном потоке стартую примерно тоже, что в вашем примере, без runLater() в принципе выкидывает exception Not in FX thread. Зато с runLater() всё работет и прогресс обновляется.

Возможно, вы вызываете метод runnCommand не в отдельном потоке или у вас проблема в другом месте. Попробуйте вызвать свой метод в отдельном потоке.

import javafx.application.Application;
import javafx.application.Platform;
import javafx.scene.Scene;
import javafx.scene.control.ProgressBar;
import javafx.scene.layout.StackPane;
import javafx.stage.Stage;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;

public class TestJFX extends Application {
    public static void main(String[] args) {
        launch(args);
    }

    @Override
    public void start(Stage primaryStage) {
        System.out.println("start");
        ProgressBar bar = new ProgressBar();
        StackPane root = new StackPane();

        root.getChildren().add(bar);
        primaryStage.setScene(new Scene(root, 300, 250));
        primaryStage.show();

         new Thread(() -> {
             System.out.println("Thread started");
             doAlot(bar);
         }).start();
    }

    public void doAlot(ProgressBar bar){
        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
        String s = "";
        try {
            while (!(s = reader.readLine()).equals("null")) {
                System.out.println("Trying to parse progress");
                Double progress = Double.parseDouble(s.split("%")[0]) / 100;
                Platform.runLater(() -> bar.setProgress(progress));
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

[zorgrhrd]

Да, я вызываю из отдельного потока, спасибо! Проблема действительно оказалась в другом, я читал буфер не в реалтайме. Ниже ответил более подробно.

Answer 3

[Николай Турнавиотов]

в c# я это делаю так:
фоновая задача в бекграунде, которая что-то долго делает, допустим в цикле.
в цикле есть вызов функции report.progress(int someint)

на функцию report.progress(int bla) висит код, который может взаимодействовать с gui и обновлять счетчик прогрессбара

Comments

[zorgrhrd]

Да, я так тоже иногда делаю, но мне в этом случае не помогло. Хотя возможно в Javafx я делаю что то не так.