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

Рекомендуем хостинг TIMEWEB

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

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

Во  время работы поверх окна приложения активно окно 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();//отключение библиотеки

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

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

connect (& futureWatcher, & QFutureWatcher <void> :: progressValueChanged, [=](){ui->ProgressBar2->setValue(25);});

connect (& futureWatcher, & QFutureWatcher <void> :: progressValueChanged, [=](){ui->ProgressBar2->setValue(25);qDebug()<<futureWatcher.progressValue();});

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

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

connect (& futureWatcher, & QFutureWatcher <void> :: progressValueChanged, [=](int progressValue){ui->ProgressBar2->setValue(progressValue);});

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

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

connect(&futureWatcher, &QFutureWatcher<void>::progressRangeChanged, ui->ProgressBar2, &QProgressBar::setRange);

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

connect (& futureWatcher, & QFutureWatcher <void> :: progressRangeChanged,  ui->ProgressBar2, & QProgressBar::setRange);

connect (& futureWatcher, & QFutureWatcher <void> :: progressValueChanged,  ui->ProgressBar2, & QProgressBar :: setValue)

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

connect (& futureWatcher, & QFutureWatcher <void> :: progressValueChanged, 
[this, &futureWatcher](){ui->ProgressBar2->setValue(25);qDebug()<<futureWatcher.progressValue();});

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

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

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

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

Дописал без

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

Сделал так

connect ( ui->ButtonStopMulti,  &QPushButton::clicked, &futureWatcher, &QFutureWatcher<void>::pause); //пауза процесса

connect ( ui->ButtonRunMulti,  &QPushButton::clicked,  &futureWatcher, &QFutureWatcher<void>::resume);  //продолжение процесса

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