Russian Qt Forum

Встала задача выполнения долгой операции в треде. Казалось бы - берем QtConcurrent и пользуемся. Но не тут-то было - в документации к QtConcurrent::run написано:
Погуглив, я ничего не нашел и полез в сорцы креатора. Оказывается, там есть чудный файлик runextensions.h (который можно, при желании, легко написать самому), который добавляет возможность уведомлять о прогрессе выполнения функции.

Вот пример использования (проект и runextensions.h можно скачать в аттаче):
Функция запускает задачу в потоке, а та пишет прогресс в диалог. Также можно отменить задачу кнопкой на диалоге.

Спасибо за находку! В документации об этом ни гу-гу.


А почему нельзя, например, передать объект QFuture напрямую в doWork()?

Потому что футура предназначена для чтения, ее нельзя (нет API) менять. Для этого сделан FurureInterface (aka std::promise)

Понятно, спасибо. Правда я вызываю метод класса и у меня выдаёт ошибку при компиляции:

Пытаюсь по Вашей аналогии вызвать:

Определение этого метода в классе:

Как такой метод можно вызвать? А если он ещё и виртуальный (virtual) - вызовется ли правильный метод в наследуемом классе?

Попробовал обёртки по типу как написано в Qt - всё равно эта ошибка вылетает при компиляции, видимо это фишка только 5-й Qt, а в qt 4.8.6 не работает. Или нет?

Потому что у вас мембер ф-ия, надо this  передать.

Я передавал this, сделал обёртку над мембер функцией, всё равно ошибку выбивает, потому, что мне QFutureInterface туда передать нужно. Пришлось сигналы привязать напрямую в контейнере классов, а хотелось бы конечно спрятать внутри класса XMLReport и диалога с ProgressBar, передав им только QFutureInterface&.

Вы runextensions.h вообще скачали?)

Конечно! :) Первым делом. И подключил.

Да, забавненько, что про QFutureInterface нет статейки в доках. Я же для отображения прогресса использовал общие переменные. Из прогрессдиалога считывал каждые 100мс.
А в qthread как-то можно следить за прогрессом иначе? Не понятен смысл строчки

Как раз понятен - т.к. интерфейс в ф-ии не передается, то она и не поддерживает.

AlekseyK
Это странно, т.к. у вас он пытается юзать оверлоады из qtcore, судя по выхлопу компилятора.

Видимо так, не знаю как его нужно было заставить использовать runextensions, потратил много времени и так и сяк - не собралось, поэтому пока сигналы привязал напрямую. А хотелось бы конечно их спрятать внутри классов и передавать только QFutureInterface.

Пример у вас работает? Пробовали добавить туда мембер ф-ию?

Пример работает, если переделать на мембер функцию - не собирается:

C++ (Qt)
#include <QApplication>
 
#include <QFuture>
#include <QFutureWatcher>
#include <QProgressDialog>
 
#include "runextensions.h"
 
class Work
{
  //heavy work :)
public:
  void doWork(QFutureInterface<void> &future)
  {
    future.setProgressRange(0, 100);
 
    static const int iterations = 10*1000*1000;
    for (int i = 0; i < iterations; i++) {
      if (future.isCanceled())
        break;
 
      future.setProgressValue(100.0*i/iterations);
 
      QObject *object = new QObject;
      object->setObjectName("Object");
      delete object;
    }
  }
};
 
int main(int argc, char *argv[])
{
    QApplication app(argc, argv);
    app.setQuitOnLastWindowClosed(false);
 
    QProgressDialog progress;
    progress.setWindowTitle(QObject::tr("Work"));
    progress.setLabelText(QObject::tr("Working..."));
    progress.setRange(0, 100);
 
    QFutureWatcher<void> watcher;
    QObject::connect(&watcher, SIGNAL(finished()), &app, SLOT(quit()));
    QObject::connect(&watcher, SIGNAL(progressValueChanged(int)), &progress, SLOT(setValue(int)));
    QObject::connect(&progress, SIGNAL(canceled()), &watcher, SLOT(cancel()));
 
    Work work;
 
    QFuture<void> future = QtConcurrent::run(work, &Work::doWork);
    watcher.setFuture(future);
    progress.show();
 
    return app.exec();
}
 

Ну сигнатуру ф-ии всё-таки смотреть надо:)

ДААААА???? :)))))))))))))) Сейчас попробуем ещё тогда. :) Спасибо! Вот на это-то времени и не хватило разобраться.

Ну как бэ

Ну да, но на примерах оно лучше :)

Собралось, спасибо! Попробуем переключить сигналы.

Ура! Всё заработало, можно отмечать тему как решённую!

Правда ещё одна проблема всплыла, не всё так красиво получилось как хотелось: сигналы из процесса не все доходят до диалога, останавливаются где-то на 60-95% почему-то: значение и текст. Пришлось опять привязать сигналы напрямую: Процесс -> ProgressDialog. Что за ерунда, почему так происходит? Если привязываем процесс -> вызов QFutureInterface::setProgressValueAndText(progressValue, message) -> ProgressDialog, то  сигналы теряются в конце.

Хз, не замечал. Установка значения происходит? как обрабатываете finished? репортите ли завершение?

Конечно, процесс заканчивается так:

C++ (Qt)
futureInterface.setProgressValueAndText(100, "C-CDA document export finished!");

C++ (Qt)
void BackgroundWorkDialog::setFuture(const QFuture<void> &future)
{
  myProcessWatcher.setFuture(future);
 
  // Connect signals
  connect(&myProcessWatcher, SIGNAL(progressValueChanged(int)),
          progressBar, SLOT(setValue(int)));
  connect(&myProcessWatcher, SIGNAL(progressTextChanged(QString)),
          label, SLOT(setText(QString)));
  connect(&myProcessWatcher, SIGNAL(finished()), this, SLOT(proccessFinish()));
}
 
void BackgroundWorkDialog::proccessFinish()
{
  // disconnect dialog hiding
  disconnect(button, SIGNAL(clicked()), this, SLOT(hide()));
 
  if(isHidden())
    show();
 
  button->setText("Done!");
  connect(button, SIGNAL(clicked()), this, SLOT(accept()));
  connect(this, SIGNAL(accepted()), this, SLOT(deleteLater()));
  connect(this, SIGNAL(rejected()), this, SLOT(deleteLater()));
 
  emit finished();
}

Вызывается точно, т.к. кнопка ВСЕГДА меняет текст на "Done!", значит future или futureWatcher вызывает finished().

Футуру лучше ставить после коннектов. Можете схематичный код таски привести?

Конечно. XML экспорт, где после каждой секции выводится:

C++ (Qt)
 
  reportProgress(10, "Generating ... section...");
  ...
  reportProgress(100, "Document export finished!");

C++ (Qt)
void XMLReport::reportProgress(int progressValue, const QString &message)
{
  future().setProgressValueAndText(progressValue, message);
 
  emit progressValueChanged(progressValue);
  if(!message.isEmpty())
    emit progressTextChanged(message);
}
 

future() возвращает QFutureInterface, который передаётся при запуске процесса.

Боже, как это все запутано, навязывается какая-то футура, с которой надо мучительно разбираться... Не лучше ли по-простому: завести атомарный счетчик и делать ему ++ в каждом расчете. А главная нитка следит за ним по таймеру и обновляет индикатор. Так по крайней мере нет расходов на сигналы (а то часто работает на индикатор а не на расчет).

К сожалению, задач может быть больше одной, соответственно и индикаторов понадобиться больше одного, значит и атомарный счетчик понадобиться не один.
В общем, получится еще запутанней, чем здесь. :)
Хотя я ничего запутанного в future не наблюдаю.

Кстати о птичках: а что произойдет если задача выбросит исключение?

Вы так кичитесь тем, что не читаете букварь, что регулярно ставите себя в дурацкое положение. Не позорьтесь, почитайте. Гугл std::future, std::promise.

Это всё интересно и познавательно, но всё же почему не все сигналы от future доходят?

Вы бы выложили компилябельный пример, как вы это делаете. Был бы проще.

???  Да я здесь даже слова "букварь" не говорил :) И как это связано с вопросом про исключение?

А зачем мне их читать если я использую OpenMP - что на мой взгляд гораздо мощнее и солиднее. Заметьте, я не говорю Вам "не позорьтесь, читайте OpenMP"  :)

std - стандартные решения популярных задач. Ну вот не было футуры, надо было городить флажок, как-то организовать ожидание, вот сделали что-то штатное, ну молодцы, спасибо. Но откуда глупейшее предубеждение что этим штатным обязательно, непременно нужно пользоваться, иначе - несмываемый позор? :) Даже "чисто объективно" никто не обещал что оно окажется здесь лучшим. Напр та же посылка сигналов может заметно тормозить если единица задачи мала.

Вы определенно "заучились" - поверьте, не тот программист лучше кто "больше знает"  :)

А зачем тогда вопросы задаете, если оно вам не надо? :)

Детский сад. :)

В букваре написано что происходит при выбросе исключения.

Чтобы уметь правильно пользоваться инструментом.

Да-да, не тот, кто больше знает, а кто городит свои велосипеды потому что "букварь для лохов".