Аварийное завершение программы при использованиии Concurrent API

[AlekseyK]

Вобщем имеем такой код:

Код:

    QEventLoop loop;
    QFutureWatcher<void> watcher;
    connect(&watcher, SIGNAL(finished()), &loop, SLOT(quit()));
    QFuture<void> future = QtConcurrent::run(this, &MyClass::MyMethod, parameters...);
    watcher.setFuture(future);
    loop.exec();

При использовании такой конструкции вылетает segmentation fault. Если просто вызвать MyMethod с параметрами, то всё работает без ошибок, но это неудобно т.к. в этом методе запускается продолжительный вычислительный процесс и хочется, чтобы он выполнялся в отдельном потоке. Если зкомментировать цикл и QFutureWatcher, то вылетает уже другая ошибка, но суть та же. Воспроизводится как в Qt 4.5.3, так и в 4.6.0-beta1, и в Windows, и в Linux.

В чём может быть проблема: это моя ошибка или баг Qt и надо им писать отчёт?

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

ASSERT: "qApp && qApp->thread() == QThread::currentThread()" in file kernel\qapplication_win.cpp, line 895
QWaitCondition: Destroyed while threads are still waiting

[Rcus]

Ну вот именно это утверждение должно гарантировать что к функциям рисования будут обращаться только из главного потока, что происходит в другой системе тоже надо смотреть, а вообще так ли сложно запустить отладчик и узнать след стека вызовов?
Я тоже не любил отладчики, но после сеанса ловли SIGSEGV при инициализации фреймбуффера без отладочных символов (памяти не хватало) очень даже полюбил их (хотя без крайней необходимости использую только для посмертного изучения процесса)

[AlekseyK]

Ну вот именно это утверждение должно гарантировать что к функциям рисования будут обращаться только из главного потока

Понятно, этот момент я видимо пропустил в документации. Благодарю! Исправил. Я использовал QTextEdit для вывода отладочной информации из этой функции и... repaint(),   чтобы что-то увидеть пока идут вычисления, т.к. они выполнялись в том же потоке, теперь я благополучно убрал ui->errorEdit->repaint() за ненадобностью, всё работает! Спасибо.

P.S. Qt таки рулит!
P.P.S. А чем всё-таки может быть связана такая особенность Qt Concurrent?

[AlekseyK]

В винде продолжает вылетать, стек ни о чём ни говорит, всегда запускаю в отладчике пока что:

Код

0	ntdll!LdrDestroyOutOfProcessImage	C:\WINDOWS\system32\ntdll.dll	0	0x7c8285f3	
1	ntdll!LdrAddRefDll	C:\WINDOWS\system32\ntdll.dll	0	0x7c82860c	
2	ntdll!ZwClose	C:\WINDOWS\system32\ntdll.dll	0	0x7c826d49	
3	??	C:\WINDOWS\system32\vfbasics.dll	0	0x00392f52	
4	??		0	0x00000000	
 

ASSERT: "qApp && qApp->thread() == QThread::currentThread()" in file kernel\qapplication_win.cpp, line 895
QWaitCondition: Destroyed while threads are still waiting
QObject::killTimers: timers cannot be stopped from another thread

В чём может быть проблема?

[AlekseyK]

Я нашёл: в моём методе оставался вызов:

ui->errorEdit->append(s);

Линукс с ним нормально работает, windows - вываливает ошибку. Я смотрю, что QtConcurrent может передавать информацию во вне только через progressText() и progressValue(). А как можно менять их значение в MyMethod?!

[SABROG]

Линукс с ним нормально работает, windows - вываливает ошибку. Я смотрю, что QtConcurrent может передавать информацию во вне только через progressText() и progressValue(). А как можно менять их значение в MyMethod?!

Это особенность потоков. ОС ни при чем. Унаследуй свой класс от QObject'a и отсылай сигналы. progressValue() меняется автоматически, если ты используешь контейнеры/списки/листы в методе типа QtConcurrent::map(). Для QtConcurrent::run() он не сигналит:

Note that the QFuture returned by QtConcurrent::run() does not support canceling, pausing, or progress reporting. The QFuture returned can only be used to query for the running/finished status and the return value of the function.

[AlekseyK]

Это особенность потоков. ОС ни при чем. Унаследуй свой класс от QObject'a и отсылай сигналы.

А он так и унаследован - от QMainWindow, а MyMethod определён в нём, и в этом же классе в другом методе создаётся QFuture объект.

progressValue() меняется автоматически, если ты используешь контейнеры/списки/листы в методе типа QtConcurrent::map(). Для QtConcurrent::run() он не сигналит:

Понятно, будем разбираться с map: с run() всё так просто - запускаешь свою функцию... ЛЮБУЮ, и порядок! Но что интересно в линуксе:

Код:

ui->errorEdit->append(s);
и
progressBar->setValue(i * 100 / cycles);

работают внутри MyMethod(), хотя похоже, что ошибки иногда всё-таки вылетают, а в винде отказывается категорически.

Note that the QFuture returned by QtConcurrent::run() does not support canceling, pausing, or progress reporting. The QFuture returned can only be used to query for the running/finished status and the return value of the function.

Понятно, спасибо, не дочитал просто до этого места.

[AlekseyK]

Блин, это ж для map придётся логику MyMethod() полностью менять?

[AlekseyK]

Note that the QFuture returned by QtConcurrent::run() does not support canceling, pausing, or progress reporting. The QFuture returned can only be used to query for the running/finished status and the return value of the function.

Я смотрю, что ты в своё время тоже на это налател:
http://www.qtcentre.org/threads/26861-QtConcurrent-i-need-advice?

А что означала твоя фраза:

Код:

I solved my task himself, with signals and slots and using QtConcurrent::run(). 

?

[AlekseyK]

Передалал код так:

Код:

    QEventLoop loop;
    QFutureWatcher<QString> watcher;
    connect(&watcher, SIGNAL(finished()), &loop, SLOT(quit()));
    // Prepare cycles vector
    QVector<int> vector;
    for (int i = 0; i < cyclesCount; i++)
        vector.append(i);
    // Run thread
    watcher.setFuture(QtConcurrent::mapped(vector,  &MyClass::MyMethod));

не собирается. Ошибка:

no matching function for call to 'mapped(QVector<int>&, QString (MyClass::*)(int&))'

Чего ему не хватает? Или он методы класса не поддерживает?

MyClass, напомню,-  производный от QMainWindow и всё в нём происходит.
Объявление MyMethod:
QString MyMethod(int &cycleNo);

[AlekseyK]

Блин, похоже он это не поддерживает и надо будет использовать QThread?

[Kolobok]

#include <QtConcurrentMap>

[AlekseyK]

#include <QtConcurrentMap>

Благодарствую, добавил. Но ошибка пока всё та же:

no matching function for call to ‘mapped(QVector<int>&, QString (MyMainWindow::*)(const int&))’

[AlekseyK]

Ау, люди???!!! Есть идеи?! Или может у кого есть пример работающего собирающегося аналогичного кода, пожалуйста?

[Kolobok]

Пример