Форум программистов, компьютерный форум, киберфорум
C++ Qt
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
 
Рейтинг 4.82/89: Рейтинг темы: голосов - 89, средняя оценка - 4.82
Эксперт С++
 Аватар для Avazart
8484 / 6151 / 615
Регистрация: 10.12.2010
Сообщений: 28,683
Записей в блоге: 30

О странностях QtConcurrent+QFuture+QFutureWatcher

22.01.2015, 13:24. Показов 16836. Ответов 36
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Вот такой код работает:
C++ (Qt)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
QString threadFunc()
{
  return QString("This is result");
}
 
QFutureWatcher<QString> watcher; // Глобальное объявление ???
QFuture<QString> future;
 
void MainWindow::on_pushButton_clicked()
{
  connect(&watcher,SIGNAL(finished()),
          this,   SLOT(on_finished()));
 
  watcher.setFuture(future);
  future = QtConcurrent::run(threadFunc);
}
 
void MainWindow::on_finished()
{
 QString text=  future.result();
 ui->textBrowser->insertPlainText(text);
}
Первый момент: Вопрос а что делать, если мне нужно несколько потоков запустить по мере появления данных, как получить каждый результат future.result() из слота on_finished и отличить их один от другого?
Как правильно распоряжаться объектами QFuture/QFutureWatcher в плане создания/уничтожения?

Второй момент: Почему код перестает работать при замене на
C++ (Qt)
1
2
3
4
5
void MainWindow::on_finished()
{
  QString text=  watcher.future().result(); //  через watcher !!!   Приложение падает
   ui->textBrowser->insertPlainText(text);
}
Но стоит сделать еще одну правку:
C++ (Qt)
1
2
3
4
5
6
7
void MainWindow::on_pushButton_clicked()
{
  connect(&watcher,SIGNAL(finished()),
          this,   SLOT(on_finished()));
 
  watcher.setFuture(QtConcurrent::run(threadFunc));  // прямиком в watcher !!!
}
Все ок!
Я так понимаю лажа с подсчетом ссылок и правами владения?
0
Programming
Эксперт
39485 / 9562 / 3019
Регистрация: 12.04.2006
Сообщений: 41,671
Блог
22.01.2015, 13:24
Ответы с готовыми решениями:

QtConcurrent::run() многоразовый вызов, очередность получения QFuture::result()
Задача следующая - есть файл, большой файл. Нужно провести по нему определенные операции - декодирование. Однопоточно это делать медленно,...

QFutureWatcher progressTextChanged
Доброго времени суток. На основе примера делаю свой прогресс-диалог и возник вопрос, как сделать чтобы QFutureWatcher посылал сигнал...

И еще раз о странностях ранжирования Гугла
Чтобы окончательно не запутаться в лабиринтах логики Гугла, вопрос к гуру: наш сайт kirillovka(тчк)com(тчк)ua по запросу...

36
 Аватар для RazrFalcon
1403 / 1260 / 262
Регистрация: 10.11.2013
Сообщений: 3,763
22.01.2015, 14:16
Цитата Сообщение от Avazart Посмотреть сообщение
отличить их один от другого
http://qt-project.org/doc/qt-4... l#resultAt

Цитата Сообщение от Avazart Посмотреть сообщение
Как правильно распоряжаться объектами QFuture/QFutureWatcher в плане создания/уничтожения?
Создаем в куче. Удаляем когда не нужны.

Цитата Сообщение от Avazart Посмотреть сообщение
Почему код перестает работать при замене на
Вероятно нужно сначала создать future, а потом его задавать.
C++ (Qt)
1
2
future = QtConcurrent::run(threadFunc);
watcher.setFuture(future);
Добавлено через 11 секунд
Цитата Сообщение от Avazart Посмотреть сообщение
Я так понимаю лажа с подсчетом ссылок и правами владения?
Нет.
0
Эксперт С++
 Аватар для Avazart
8484 / 6151 / 615
Регистрация: 10.12.2010
Сообщений: 28,683
Записей в блоге: 30
22.01.2015, 14:36  [ТС]
Цитата Сообщение от RazrFalcon Посмотреть сообщение
Вероятно нужно сначала создать future, а потом его задавать.
Да в оф доке именно так:
C++ (Qt)
1
2
3
4
5
6
7
8
// Instantiate the objects and connect to the finished signal.
MyClass myObject;
QFutureWatcher<int> watcher;
connect(&watcher, SIGNAL(finished()), &myObject, SLOT(handleFinished()));
 
// Start the computation.
QFuture<int> future = QtConcurrent::run(...);
watcher.setFuture(future);
http://doc.qt.io/qt-5/qfuturewatcher.html

Но дело в том что я опирался на пример из книги Боровского (стр. 234), там установка "до"
Затем с помощью метода setFuture()
мы передаем объекту QFutureWatcher ссылку на конкретный объект QFuture. Обра-
тите внимание, что все это необходимо выполнить до вызова функции run(), иначе
события, которые мы хотим отслеживать, могут произойти в промежутке между
вызовом run() и настройкой QFutureWatcher
.
что логично.

Добавлено через 2 минуты
Цитата Сообщение от RazrFalcon Посмотреть сообщение
Нет.
Почему нет? QFuture передается объекту QFutureWatcher значит не должно быть проблем, он должен им влядеть(ну или его содержимым)
Цитата Сообщение от RazrFalcon Посмотреть сообщение
Создаем в куче. Удаляем когда не нужны.
Почему тогда в примерах все "по значению" передается?

Добавлено через 2 минуты
Цитата Сообщение от RazrFalcon Посмотреть сообщение
http://qt-project.org/doc/qt-4.8/qfuture.html#resultAt
Честно говоря не понял как это использовать, можно пример?
0
1443 / 1326 / 131
Регистрация: 20.03.2009
Сообщений: 4,689
Записей в блоге: 11
22.01.2015, 14:49
Цитата Сообщение от Avazart Посмотреть сообщение
Но дело в том что я опирался на пример из книги Боровского (стр. 234), там установка "до"
Это говорит о том, что строчка
C++ (Qt)
1
connect(&watcher, SIGNAL(finished()), &myObject, SLOT(handleFinished()));
должна быть вызвана, до вызова run. Иначе может произойти состояние гонки.
1
Эксперт С++
 Аватар для Avazart
8484 / 6151 / 615
Регистрация: 10.12.2010
Сообщений: 28,683
Записей в блоге: 30
22.01.2015, 14:54  [ТС]
Цитата Сообщение от Dmitriy_M Посмотреть сообщение
Это говорит о том, что строчка
C++ (Qt)
1
connect(&watcher, SIGNAL(finished()), &myObject, SLOT(handleFinished()));
должна быть вызвана, до вызова run. Иначе может произойти состояние гонки.
Ну так в той же книге пример:
C++ (Qt)
1
2
3
4
5
6
QFuture<quint64> future;
QFutureWatcher<quint64> watcher;
connect(&watcher, SIGNAL(finished()), this, SLOT(finished()));
watcher.setFuture(future);
qint32 n = 100;
future = QtConcurrent::run(fibonacci, n);
Что говори что имелась ввиду и установка watcher.setFuture(future);


По поводу
Цитата Сообщение от Avazart Посмотреть сообщение
Первый момент: Вопрос а что делать, если мне нужно несколько потоков запустить по мере появления данных, как получить каждый результат future.result() из слота on_finished и отличить их один от другого?
Как правильно распоряжаться объектами QFuture/QFutureWatcher в плане создания/уничтожения?
Родилось такое примерно решение:
Пример кода
C++ (Qt)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
typedef QFutureWatcher<QString> Watcher;
//----------------------------------------
QString threadFunc(int n)
{
  QThread::sleep(qrand()%5);
  QString msg=
   QString("Thread №%1 \t task №%2  finished.\r\n")
     .arg(QString::number(
             (int)QThread::currentThreadId()))// Thread HANDLE, not Id
     .arg(QString::number(n));
  return msg;
}
//----------------------------------------
void MainWindow::createTask(int n)
{
  Watcher* watcher= new Watcher;
  connect(watcher,SIGNAL(finished()),
          this,   SLOT(on_finished()));
  watcher->setFuture(QtConcurrent::run(threadFunc,n));
}
//----------------------------------------
void MainWindow::on_pushButton_clicked()
{
  for(int i=0; i< 10; ++i)
    createTask(i);
}
//----------------------------------------
void MainWindow::on_finished()
{
 Watcher* watcher=
    static_cast<Watcher*>(sender());
 Q_ASSERT(watcher);
 
 QString text= watcher->result();
 watcher->deleteLater();
 ui->textBrowser->insertPlainText(text);
}
//----------------------------------------
0
 Аватар для RazrFalcon
1403 / 1260 / 262
Регистрация: 10.11.2013
Сообщений: 3,763
22.01.2015, 15:02
Цитата Сообщение от Avazart Посмотреть сообщение
Почему тогда в примерах все "по значению" передается?
Хз, может ошибка. watcher из примера удалится до окончания ::run().

Цитата Сообщение от Avazart Посмотреть сообщение
Честно говоря не понял как это использовать, можно пример?
C++ (Qt)
1
2
3
4
5
6
7
int pos = 0;
 
void MainWindow::on_finished()
{
    QString text= watcher->result(pos++);
    ui->textBrowser->insertPlainText(text);
}
Ваш пример некорректен, так как вы сразу удаляете watcher, а выше писали что у вас несколько результатов может быть.
0
Эксперт С++
 Аватар для Avazart
8484 / 6151 / 615
Регистрация: 10.12.2010
Сообщений: 28,683
Записей в блоге: 30
22.01.2015, 15:02  [ТС]
Цитата Сообщение от Avazart Посмотреть сообщение
Что говори что имелась ввиду и установка watcher.setFuture(future);
Хотя вероятно это ошибочное утверждение ведь сообщение finished() все равно не будет обработано в очереди сообщений пока слот кнопки(on_pushButton_clicked()) не выполнится полностью.
0
 Аватар для RazrFalcon
1403 / 1260 / 262
Регистрация: 10.11.2013
Сообщений: 3,763
22.01.2015, 15:02
Цитата Сообщение от Avazart Посмотреть сообщение
Ну так в той же книге пример:
В книге может быть, сюрприз-сюрприз, ошибка.
0
Эксперт С++
 Аватар для Avazart
8484 / 6151 / 615
Регистрация: 10.12.2010
Сообщений: 28,683
Записей в блоге: 30
22.01.2015, 15:04  [ТС]
Цитата Сообщение от RazrFalcon Посмотреть сообщение
Ваш пример некорректен, так как вы сразу удаляете watcher, а выше писали что у вас несколько результатов может быть.
Я имел ввиду что несколько раз вызываться QtConcurrent::run(), а значит будет и несколько watcher-ов.
0
 Аватар для RazrFalcon
1403 / 1260 / 262
Регистрация: 10.11.2013
Сообщений: 3,763
22.01.2015, 15:09
Цитата Сообщение от Avazart Посмотреть сообщение
несколько раз вызываться QtConcurrent::run
Для этого есть ::map()
0
Эксперт С++
 Аватар для Avazart
8484 / 6151 / 615
Регистрация: 10.12.2010
Сообщений: 28,683
Записей в блоге: 30
22.01.2015, 15:12  [ТС]
Цитата Сообщение от RazrFalcon Посмотреть сообщение
В книге может быть, сюрприз-сюрприз, ошибка.
Так то оно так, но выглядело вполне логичным с первого взгляда.
И причина тому вероятно трудности с пониманием которые порождает асинхронность.

Добавлено через 1 минуту
Цитата Сообщение от RazrFalcon Посмотреть сообщение
Для этого есть ::map()
Нет, map() для готового заранее известного набора данных, а не поступающих "по мере" какого-то процесса.(например получения с сети или перебора файлов)
0
 Аватар для RazrFalcon
1403 / 1260 / 262
Регистрация: 10.11.2013
Сообщений: 3,763
22.01.2015, 15:14
Цитата Сообщение от Avazart Посмотреть сообщение
Нет, map() для готового заранее известного набора данных, а не поступающих "по мере" какого-то процесса.
Тогда и результат будет всегда один. То есть простого result() достаточно.
0
Эксперт С++
 Аватар для Avazart
8484 / 6151 / 615
Регистрация: 10.12.2010
Сообщений: 28,683
Записей в блоге: 30
22.01.2015, 15:37  [ТС]
Цитата Сообщение от RazrFalcon Посмотреть сообщение
Тогда и результат будет всегда один. То есть простого result() достаточно.
Ну только через sender() ведь неизвестно когда именно та или иная завершится.

Добавлено через 7 минут
Dmitriy_M,
Цитата Сообщение от Dmitriy_M Посмотреть сообщение
C++ (Qt)
1
connect(&watcher, SIGNAL(finished()), &myObject, SLOT(handleFinished()));
должна быть вызвана, до вызова run. Иначе может произойти состояние гонки.
Кстати это тоже выходит не правильно.
0
 Аватар для RazrFalcon
1403 / 1260 / 262
Регистрация: 10.11.2013
Сообщений: 3,763
22.01.2015, 16:06
Avazart, неправильный мой пример был. Вот верный вариант: http://qt-project.org/doc/qt-4... ultReadyAt
То есть сигнал есть с указанием какой результат можно забирать когда он готов.

Добавлено через 19 секунд
Цитата Сообщение от Avazart Посмотреть сообщение
Кстати это тоже выходит не правильно.
Почему?
0
Эксперт С++
 Аватар для Avazart
8484 / 6151 / 615
Регистрация: 10.12.2010
Сообщений: 28,683
Записей в блоге: 30
22.01.2015, 16:17  [ТС]
Цитата Сообщение от RazrFalcon Посмотреть сообщение
Почему?
По тому что пока слот кнопки полностью не выполнится и не "вернется", все равно не будет обработки сообщений, ведь слот и сообщения обрабатываются в одном потоке.
0
 Аватар для RazrFalcon
1403 / 1260 / 262
Регистрация: 10.11.2013
Сообщений: 3,763
22.01.2015, 16:25
Avazart, нет. Сигнал от "run" может прийти до завершения текущего метода. И если коннекта не было - то этот сигнал приспустится.
0
Эксперт С++
 Аватар для Avazart
8484 / 6151 / 615
Регистрация: 10.12.2010
Сообщений: 28,683
Записей в блоге: 30
22.01.2015, 16:27  [ТС]
Цитата Сообщение от RazrFalcon Посмотреть сообщение
Avazart, нет. Сигнал от "run" может прийти до завершения текущего метода.
Да он о то может завершится раньше и выслать сообщение, но сообщение может обработано только после завершения слота кнопки.
0
 Аватар для RazrFalcon
1403 / 1260 / 262
Регистрация: 10.11.2013
Сообщений: 3,763
22.01.2015, 16:29
Avazart, хз, нужно писать тестовый пример.
0
Эксперт С++
 Аватар для Avazart
8484 / 6151 / 615
Регистрация: 10.12.2010
Сообщений: 28,683
Записей в блоге: 30
22.01.2015, 16:31  [ТС]
Ну вот такой код:

C++ (Qt)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
typedef QFutureWatcher<QString> Watcher;
//----------------------------------------
QString threadFunc(int n)
{
  QString msg=
   QString("Thread №%1 \t task №%2  finished.\r\n")
     .arg(QString::number(
             (int)QThread::currentThreadId()))// Thread HANDLE, not Id
     .arg(QString::number(n));
  return msg;
}
//----------------------------------------
void MainWindow::createTask(int n)
{
  Watcher* watcher= new Watcher;
  watcher->setFuture(QtConcurrent::run(threadFunc,n));
 
  QThread::sleep(30);  /* Имитируем что тут "вклинился" другой поток.
                            и забрал процессорное время*/
  /*через 30 cек после запуска */
  connect(watcher,SIGNAL(finished()),
          this,   SLOT(on_finished()));
}
//----------------------------------------
void MainWindow::on_pushButton_clicked()
{
    createTask(0);
}
//---------------------------------------
void MainWindow::on_finished()
{
 Watcher* watcher=
    static_cast<Watcher*>(sender());
 Q_ASSERT(watcher);
 
 QString text= watcher->result();
 ui->textBrowser->insertPlainText(text);
  watcher->deleteLater();
}
//---------------------------------------
0
 Аватар для RazrFalcon
1403 / 1260 / 262
Регистрация: 10.11.2013
Сообщений: 3,763
22.01.2015, 16:34
Avazart, так есть разница или нет?
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
inter-admin
Эксперт
29715 / 6470 / 2152
Регистрация: 06.03.2009
Сообщений: 28,500
Блог
22.01.2015, 16:34
Помогаю со студенческими работами здесь

QtConcurrent
Здравствуйте, хочу сделать сервер многопоточным, через concurrent. Делаю так void chatServer::incomingConnection(int desc) { ...

QtConcurrent и bind
Доброго времени суток. Есть вот такой незамысловатый код: #include &lt;QCoreApplication&gt; #include &lt;QDebug&gt; #include...

Не работает QtConcurrent
void Object::loadObjModel(const std::string filename) { .... std::string line; while(std::getline(object, line)) ...

QtConcurrent::mapped
Заранее извиняюсь. Вопрос достаточно глупый, но всё же QStringList lst (QStringList ( ) &lt;&lt; &quot;one&quot; &lt;&lt; &quot;two&quot;...

Использование в qtconcurrent::run() ui->
Доброго времени, форумчане! При сабже программа вылетает. Как быть? Возможно ли из лямбды послать сигнал(как же по-нубски звучит этот...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
20
Ответ Создать тему
Новые блоги и статьи
Access
VikBal 11.12.2025
Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.
Новый ноутбук
volvo 07.12.2025
Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro
Музыка, написанная Искусственным Интеллектом
volvo 04.12.2025
Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .
От async/await к виртуальным потокам в Python
IndentationError 23.11.2025
Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .
Поиск "дружественных имён" СОМ портов
Argus19 22.11.2025
Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .
Сколько Государство потратило денег на меня, обеспечивая инсулином.
Programma_Boinc 20.11.2025
Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .
Ломающие изменения в C#.NStar Alpha
Etyuhibosecyu 20.11.2025
Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .
Мысли в слух
kumehtar 18.11.2025
Кстати, совсем недавно имел разговор на тему медитаций с людьми. И обнаружил, что они вообще не понимают что такое медитация и зачем она нужна. Самые базовые вещи. Для них это - когда просто люди. . .
Создание Single Page Application на фреймах
krapotkin 16.11.2025
Статья исключительно для начинающих. Подходы оригинальностью не блещут. В век Веб все очень привыкли к дизайну Single-Page-Application . Быстренько разберем подход "на фреймах". Мы делаем одну. . .
Фото: Daniel Greenwood
kumehtar 13.11.2025
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2025, CyberForum.ru