М
Миша16 декабря 2017 г. 12:11

Пауза в многопоточности

Здравствуйте, можно ли поставить процесс на паузу при выполнении функций в многопоточности QtConcurrent::map?

Рекомендуем хостинг TIMEWEB
Рекомендуем хостинг TIMEWEB
Стабильный хостинг, на котором располагается социальная сеть EVILEG. Для проектов на Django рекомендуем VDS хостинг.

Вам это нравится? Поделитесь в социальных сетях!

18
Evgenii Legotckoi
  • 16 декабря 2017 г. 12:23
  • (ред.)

QFuture, который возвращается QtConcurrent::map имеет методы pause() и resume() и теоретически должен поддерживать этот функционал.


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

Поэтому просто проверьте, будут ли работать те методы. Если будут работать, то всё ОК, если не будут, значит это также как и для QtConcurrent::run не поддерживается.
    М
    • 17 декабря 2017 г. 2:30

    Во  время работы поверх окна приложения активно окно QProgressDialog. И у него есть только одна кнопка. Код выглядит следующим образом. Можно ли добавить еще две кнопки или диалог баттон бокс в окно QProgressDialog? Или можно как то иначе произвести сигнал?

    QProgressDialog dialog;
    
           // Создать объект QFutureWatcher и подключить сигналы и слоты к диалогу.
           // Мониторинг прогресса изменений для future
           QFutureWatcher<void> futureWatcher;
           connect(&futureWatcher, &QFutureWatcher<void>::finished, &dialog, &QProgressDialog::reset);
           connect(&dialog, &QProgressDialog::canceled, &futureWatcher, &QFutureWatcher<void>::cancel);
           connect(&dialog, &QProgressDialog::canceled,[this](){StopStrategy=true;});
           connect(&futureWatcher, &QFutureWatcher<void>::progressRangeChanged, &dialog, &QProgressDialog::setRange);
           connect(&futureWatcher, &QFutureWatcher<void>::progressValueChanged, &dialog, &QProgressDialog::setValue);
    
    
    
           //QFuture<void> Perebor1 = QtConcurrent::map(Perebor,[this](const double& d){ StrategyCod2(d);});  //просчет стратегии в нескольхих потоках
           FileForRecord.open(QIODevice::WriteOnly);  //открывает файл на запись
    
           QLibrary MyLib("C:\\Qt\\project\\build-StrategyCod-Desktop_Qt_5_9_2_MinGW_32bit-Debug\\debug\\StrategyCod");  //путь к библиотеке
           MyLib.unload();//отключение библиотеки
           MyLib.load();//чтение
           typedef void (*MyPrototype)(double,MainWindow *);
           MyPrototype StrategyCod = (MyPrototype) MyLib.resolve("StrategyCod");
           futureWatcher.setFuture(QtConcurrent::map(Perebor,[=](const double& d){ StrategyCod(d,this);}));
           // Показать диалог и запустить программную петлю диалога
           dialog.exec();
    
           futureWatcher.waitForFinished();
           MyLib.unload();//отключение библиотеки

     

      Evgenii Legotckoi
      • 17 декабря 2017 г. 4:55

      Если честно, здесь уже проще самому написать нужный класс.

      Дело в том, что QProgressDialog не имеет QDialogButtonBox , как впрочем и QDialog . Да, в QProgressDialog есть кнопка отмена , но только она там и есть. А QDialog вообще не имеет кнопок и QDialogButtonBox`а .
      Но QDialog используется как база для создания своих диалоговых окон.
      Так что на мой взгляд, проще создать свой прогресс диалог и реализовать самостоятельно весь необходимый функционал. В конце концов есть и отдельный виджет прогресс бара, который можно использовать в собственном диалоге.
      Ещё можно, конечно, наследоваться от QProgressDialog`a, но скорее всего это будет несколько более усложнённым решением в плане вёрстки.
        М
        • 18 декабря 2017 г. 8:03

        У меня есть QProgressBar "ui->ProgressBar2".

        Можно ли ему аналогично передавать значение объема?
        Могу написать так
        connect (& futureWatcher, & QFutureWatcher <void> :: progressValueChanged, [=](){ui->ProgressBar2->setValue(25);});
        Но как задать значение прогресса?
        Если пишу так, то сразу 10 ошибок
        connect (& futureWatcher, & QFutureWatcher <void> :: progressValueChanged, [=](){ui->ProgressBar2->setValue(25);qDebug()<<futureWatcher.progressValue();});

          Evgenii Legotckoi
          • 18 декабря 2017 г. 8:11

          Киньте текст ошибок. Хотя у меня подозрение, что вы просто забыли/удалили #include <QDebug>

            М
            • 18 декабря 2017 г. 8:13
            C:\Qt\project\MyCandleSrick\mainwindow.cpp:1116: ошибка: use of deleted function 'QFutureWatcher<void>::QFutureWatcher(const QFutureWatcher<void>&)'
            connect (& futureWatcher, & QFutureWatcher <void> :: progressValueChanged, [=](){ui->ProgressBar2->setValue(25);qDebug()<<futureWatcher.progressValue();});
            ^
            C:\Qt\Qt5.9.2\5.9.2\mingw53_32\include\QtCore\qfuturewatcher.h:185: ошибка: use of deleted function 'QFutureWatcherBase::QFutureWatcherBase(const QFutureWatcherBase&)'
            C:\Qt\Qt5.9.2\5.9.2\mingw53_32\include\QtCore\qobject.h:454: ошибка: 'QObject::QObject(const QObject&)' is private
            Q_DISABLE_COPY(QObject)
            ^
            C:\Qt\Qt5.9.2\5.9.2\mingw53_32\include\QtCore\qfuturewatcher.h:55: ошибка: within this context
            class Q_CORE_EXPORT QFutureWatcherBase : public QObject
            ^
            C:\Qt\Qt5.9.2\5.9.2\mingw53_32\include\QtCore\qfuturewatcher.h:55: ошибка: use of deleted function 'QObject::QObject(const QObject&)'
            C:\Qt\project\MyCandleSrick\mainwindow.cpp:1116: ошибка: use of deleted function 'MainWindow::on_ButtonRunMulti_clicked()::<lambda()>::<lambda>(MainWindow::on_ButtonRunMulti_clicked()::<lambda()>&&)'
            connect (& futureWatcher, & QFutureWatcher <void> :: progressValueChanged, [=](){ui->ProgressBar2->setValue(25);qDebug()<<futureWatcher.progressValue();});
            ^
            C:\Qt\project\MyCandleSrick\mainwindow.cpp:1116: ошибка: use of deleted function 'QFutureWatcher<void>::QFutureWatcher(const QFutureWatcher<void>&)'
            C:\Qt\Qt5.9.2\5.9.2\mingw53_32\include\QtCore\qobject.h:307: ошибка: use of deleted function 'MainWindow::on_ButtonRunMulti_clicked()::<lambda()>::<lambda>(const MainWindow::on_ButtonRunMulti_clicked()::<lambda()>&)'
            return connect(sender, signal, sender, slot, Qt::DirectConnection);
            ^
            C:\Qt\project\MyCandleSrick\mainwindow.cpp:1116: ошибка: use of deleted function 'QFutureWatcher<void>::QFutureWatcher(const QFutureWatcher<void>&)'
            C:\Qt\Qt5.9.2\5.9.2\mingw53_32\include\QtCore\qobject.h:313: ошибка: 'static typename std::enable_if<(QtPrivate::FunctionPointer<Func2>::ArgumentCount == (-1)), QMetaObject::Connection>::type QObject::connect(const typename QtPrivate::FunctionPointer<Func>::Object*, Func1, const QObject*, Func2, Qt::ConnectionType) [with Func1 = void (QFutureWatcherBase::*)(int); Func2 = MainWindow::on_ButtonRunMulti_clicked()::<lambda()>; typename std::enable_if<(QtPrivate::FunctionPointer<Func2>::ArgumentCount == (-1)), QMetaObject::Connection>::type = QMetaObject::Connection; typename QtPrivate::FunctionPointer<Func>::Object = QFutureWatcherBase]', declared using local type 'MainWindow::on_ButtonRunMulti_clicked()::<lambda()>', is used but never defined [-fpermissive]

              Evgenii Legotckoi
              • 18 декабря 2017 г. 8:13

              А вообще, можно и сигнал/слотовое соединение переписать.

              connect (& futureWatcher, & QFutureWatcher <void> :: progressValueChanged, [=](int progressValue){ui->ProgressBar2->setValue(progressValue);});
              Сигнал же уже в качестве аргумента передаёт изменение прогресса.
                М
                • 18 декабря 2017 г. 8:22

                при такой записи прогресс бар остается на месте, qDebug ничего не пишет. видимо значение  progressValue не определенно. думаю, нужна ссылка на значение прогресса


                  Evgenii Legotckoi
                  • 18 декабря 2017 г. 8:28
                  • (ред.)

                  Я конечно сталкивался с тем, что некоторый функционал Qt не работает под некоторыми ОС, но то, что не передаётся информация о прогрессе из QFuture - это сомнительно. А вы устанавливаете диапазон значений для прогресс бара?

                  connect(&futureWatcher, &QFutureWatcher<void>::progressRangeChanged, ui->ProgressBar2, &QProgressBar::setRange);
                  Возможно из-за того, что значения диапазона изначально не определены, то и значения текущего прогресса, передаваемые из QFuture, являются ошибочными.
                    М
                    • 18 декабря 2017 г. 8:35

                    оно у меня стоит от 0 до 100

                    сделал так, все еще не работает
                    connect (& futureWatcher, & QFutureWatcher <void> :: progressRangeChanged,  ui->ProgressBar2, & QProgressBar::setRange);
                    connect (& futureWatcher, & QFutureWatcher <void> :: progressValueChanged,  ui->ProgressBar2, & QProgressBar :: setValue)
                      Evgenii Legotckoi
                      • 18 декабря 2017 г. 8:36

                      Что касается этой ошибки, то по факту здесь запрещено копирование QFuture объекта, которое происходит в данном коде.
                      Можно переписать так для данной лямбды.

                      connect (& futureWatcher, & QFutureWatcher <void> :: progressValueChanged, 
                      [this, &futureWatcher](){ui->ProgressBar2->setValue(25);qDebug()<<futureWatcher.progressValue();});
                        М
                        • 18 декабря 2017 г. 8:38

                        может быть мое окно не активно, пока работает

                        futureWatcher.setFuture(QtConcurrent::map(Perebor,[=](const double& d){ StrategyCod(d,this); }));
                          М
                          • 18 декабря 2017 г. 8:44

                          Все работает если включить dialog.exec(); . Но как сделать так, что бы работало без диалогового окна?

                            Evgenii Legotckoi
                            • 18 декабря 2017 г. 8:53

                            То есть вы пытаетесь использовать QProgressBar, а также не удалили код из самого начала этого топика, который относится к QProgressDialog?

                            ... Тогда понятно. Скорее всего слот у вас выполняется раньше, чем успевает закончится расчёт. Диалог QProgressDialog нужно удалять отсюда, если он Вам уже не требуется.
                            А вот задержку выполнения кода можно попробовать сделать через QEventLoop
                            QEventLoop loop;
                            loop.connect(&futureWatcher, QFutureWatcher<void>::finished, &loop, &QEventLoop::exit);
                            // Некоторый код для QtConcurrent
                            futureWatcher.setFuture(QtConcurrent::map(Perebor,[=](const double& d){ StrategyCod(d,this);}));
                            loop.exec()
                              М
                              • 18 декабря 2017 г. 9:06

                              Дописал без

                              loop.connect(&futureWatcher, QFutureWatcher<void>::finished, &loop, &QEventLoop::exit);
                              и заработало
                                Evgenii Legotckoi
                                • 18 декабря 2017 г. 9:09

                                упс... я немного неправильно тот слот написал, ну да ладно... главное, что заработало

                                  М
                                  • 18 декабря 2017 г. 9:27
                                  • (ред.)

                                  Сделал так

                                  connect ( ui->ButtonStopMulti,  &QPushButton::clicked, &futureWatcher, &QFutureWatcher<void>::pause); //пауза процесса
                                  connect ( ui->ButtonRunMulti,  &QPushButton::clicked,  &futureWatcher, &QFutureWatcher<void>::resume);  //продолжение процесса
                                  и все наконец заработало. Большое спасибо.

                                    Evgenii Legotckoi
                                    • 18 декабря 2017 г. 9:34

                                    futureWatcher является локальной переменной в вашем коде... возможно, что при установке расчёта на паузу завершается выполнение слота, что ведёт к уничтожению объекта futureWatcher со всеми вытекающими результатами, в том числе и уничтожением сигнал-слотового соединения с кнопкой возобновления процесса.

                                    Закиньте вывод qDebug() << "check"; в конце слота и посмотрите, если будет вывод, то значит слот завершается. нужно иначе продумывать логику, чтобы объекты не уничтожались раньше времени.

                                      Комментарии

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

                                      C++ - Тест 002. Константы

                                      • Результат:16баллов,
                                      • Очки рейтинга-10
                                      B

                                      C++ - Тест 001. Первая программа и типы данных

                                      • Результат:46баллов,
                                      • Очки рейтинга-6
                                      FL

                                      C++ - Тест 006. Перечисления

                                      • Результат:80баллов,
                                      • Очки рейтинга4
                                      Последние комментарии
                                      k
                                      kmssr9 февраля 2024 г. 5:43
                                      Qt Linux - Урок 001. Автозапуск Qt приложения под Linux как сделать автозапуск для флэтпака, который не даёт создавать файлы в ~/.config - вот это вопрос ))
                                      АК
                                      Анатолий Кононенко5 февраля 2024 г. 12:50
                                      Qt WinAPI - Урок 007. Работаем с ICMP Ping в Qt Без строки #include <QRegularExpressionValidator> в заголовочном файле не работает валидатор.
                                      EVA
                                      EVA25 декабря 2023 г. 21:30
                                      Boost - статическая линковка в CMake проекте под Windows Ошибка LNK1104 часто возникает, когда компоновщик не может найти или открыть файл библиотеки. В вашем случае, это файл libboost_locale-vc142-mt-gd-x64-1_74.lib из библиотеки Boost для C+…
                                      J
                                      JonnyJo25 декабря 2023 г. 19:38
                                      Boost - статическая линковка в CMake проекте под Windows Сделал всё по-как у вас, но выдаёт ошибку [build] LINK : fatal error LNK1104: не удается открыть файл "libboost_locale-vc142-mt-gd-x64-1_74.lib" Хоть убей, не могу понять в чём дел…
                                      G
                                      Gvozdik19 декабря 2023 г. 8:01
                                      Qt/C++ - Урок 056. Подключение библиотеки Boost в Qt для компиляторов MinGW и MSVC Для решения твой проблемы добавь в файл .pro строчку "LIBS += -lws2_32" она решит проблему , лично мне помогло.
                                      Сейчас обсуждают на форуме
                                      P
                                      Pisych27 февраля 2023 г. 15:04
                                      Как получить в массив значения из связанной модели? Спасибо, разобрался:))
                                      AC
                                      Alexandru Codreanu19 января 2024 г. 22:57
                                      QML Обнулить значения SpinBox Доброго времени суток, не могу разобраться с обнулением значение SpinBox находящего в делегате. import QtQuickimport QtQuick.ControlsWindow { width: 640 height: 480 visible: tr…
                                      BlinCT
                                      BlinCT27 декабря 2023 г. 19:57
                                      Растягивать Image на парент по высоте Ну и само собою дял включения scrollbar надо чтобы был Flickable. Так что выходит как то так Flickable{ id: root anchors.fill: parent clip: true property url linkFile p…
                                      Дмитрий
                                      Дмитрий10 января 2024 г. 15:18
                                      Qt Creator загружает всю оперативную память Проблема решена. Удалось разобраться с помощью утилиты strace. Запустил ее: strace ./qtcreator Начал выводиться весь лог работы креатора. В один момент он начал считывать фай…
                                      Evgenii Legotckoi
                                      Evgenii Legotckoi12 декабря 2023 г. 17:48
                                      Побуквенное сравнение двух строк Добрый день. Там случайно не высылается этот сигнал textChanged ещё и при форматировани текста? Если решиать в лоб, то можно просто отключать сигнал/слотовое соединение внутри слота и …

                                      Следите за нами в социальных сетях