[Решено] Thread tried to wait on itself

[sergek]

Коллеги,
в одной библиотеке встретил любопытный способ использования QThread, попробовал на примере, приведенном в справке Qt (https://doc.qt.io/qt-5/qthread.html). В примере перенос объекта Worker в поток осуществляется в конструкторе Controller с ожиданием его завершения в деструкторе:

Код

C++ (Qt)
Controller::Controller(QObject *parent) : QObject(parent)
{
    worker = new Worker;
    worker->moveToThread(&workerThread);
    workerThread.start();
}
Controller::~Controller() {
    workerThread.quit();
    workerThread.wait();
    worker->deleteLater();
}
 

А в библиотеке, о которой я упоминал, это делается в самом Worker:

Код

C++ (Qt)
Worker::Worker(QObject *parent) : QObject(parent)
{
    workerThread = new QThread;
    moveToThread(workerThread);
    workerThread->start();
}
 
Worker::~Worker() {
    workerThread->quit();
    workerThread->wait();
    workerThread->deleteLater();
}

Но при этом формируется предупреждение "QThread::wait: Thread tried to wait on itself". Это сообщение понятно: ждать в себе завершения самого себя бессмысленно)) Но в чем принципиальная ошибочность моего кода?
В присоединенном архиве - пример второго способа.

[ssoft]

ждать в себе завершения самого себя бессмысленно)).

Это ж и есть ответ на вопрос.

Вызов деструктора Worker производится в активности потока workerThread, который и предлагается подождать с помощью workerThread->wait().
В первом же варианте вызов деструктора Controller производится в активности другого (скорее всего, главного) потока, связанного с объектом Controller. Здесь можно и подождать workerThread->wait().

[sergek]

Собственно, это всего лишь предупреждение, и wait в этом случае ничего не делает. Убираем wait, остается выход из циклов обработки событий quit и отложенное удаление объекта QThread с помощью deleteLater. Вопрос остается - это правильно?

[Igors]

Собственно, это всего лишь предупреждение, и wait в этом случае ничего не делает. Убираем wait, остается выход из циклов обработки событий quit и отложенное удаление объекта QThread с помощью deleteLater. Вопрос остается - это правильно?

Может избавиться от сообщения так

Код

C++ (Qt)
Worker::~Worker() {
    workerThread->quit();
    if (QThread::currentThread() != workerThread)
     workerThread->wait();
    workerThread->deleteLater();
}

[ssoft]

Собственно, это всего лишь предупреждение, и wait в этом случае ничего не делает. Убираем wait, остается выход из циклов обработки событий quit и отложенное удаление объекта QThread с помощью deleteLater. Вопрос остается - это правильно?

Удаление объекта QThread само по себе не завершает активность (Note that deleting a QThread object will not stop the execution of the thread it manages.).
Метод wait же ожидает завершения активности.

В общем случае, второй вариант допускает "подвешивание" незавершенных активностей, особенно если они реализованы в виде бесконечных циклов (когда реализована собственная версия метода MyThread::run() ).

[ssoft]

Всё даже может быть намного хуже, если полностью прочитать документацию)).

Note that deleting a QThread object will not stop the execution of the thread it manages. Deleting a running QThread (i.e. isFinished() returns false) will result in a program crash. Wait for the finished() signal before deleting the QThread.

[sergek]

Может избавиться от сообщения так

Именно так и реализовано в Qt ))

[sergek]

Всё даже может быть намного хуже, если полностью прочитать документацию)).

Note that deleting a QThread object will not stop the execution of the thread it manages. Deleting a running QThread (i.e. isFinished() returns false) will result in a program crash. Wait for the finished() signal before deleting the QThread.

Если не ошибаюсь, это предупреждение об прямом удалении с помощью delete. Я ж использую deleteLater. Правда, глубоко не залезал в реализацию, а там стоит wait))
Так можно или нельзя и почему?

[ssoft]

Вот пример по шагам

Код

C++ (Qt)
// деструктор вызывается в потоке workerThread
Worker::~Worker() {
    // в потоке workerThread обращаемся к объекту главного потока workerThread
    // (возможны проблемы с конкурентным доступом) с командой завершения QEventLoop 
    workerThread->quit();
 
    // в потоке workerThread обращаемся к объекту главного потока workerThread
    // (возможны проблемы с конкурентным доступом) с командой ожидания завершения активности данного потока
    // получаем игнорирование команды и не завершенный поток workerThread
    workerThread->wait();
 
    // в очередь главный поток отправляем событие удаления объекта workerThread,
    // которое может быть обработано в главном потоке даже до завершения этого деструктора,
    // когда активность потока workerThread фактически не завершена.
    workerThread->deleteLater();
}

[Авварон]

Но в чем принципиальная ошибочность моего кода?

Так у вас телега впереди лошади.
QThread - это объект-хэндл треда, а не сам тред (сам тред - это то, что в run()). Хэндл нужен для управления тредом из родительского (часто главного) треда - родительский поток запускает новый поток, он же его останавливает и дожидается.
А так у вас получается что владелец потока (объект Worker) перемещен внутрь этого потока, а тред не может заджойнить сам себя.

[sergek]

Хэндл нужен для управления тредом из родительского (часто главного) треда - родительский поток запускает новый поток, он же его останавливает и дожидается.

Спасибо за напоминание, что "хэндл" живет в потоке, в котором он создан)) Но откуда следует, что остановить поток (quit) можно только из того потока, откуда он был запущен?

[Авварон]

Спасибо за напоминание, что "хэндл" живет в потоке, в котором он создан)) Но откуда следует, что остановить поток (quit) можно только из того потока, откуда он был запущен?

Ни откуда, quit() можно звать из любого потока.
Нельзя звать wait() из потока потому что, по сути, wait() - это join() - вы ждете когда две нитки сольются в одну (ту, которая вызвала wait()/join()). Как нитка может поджойнится сама с собой?

[sergek]

Иначе говоря, код

Код

C++ (Qt)
Worker::~Worker() {
    workerThread->quit();
    workerThread->deleteLater();
}
 

корректен?

[ssoft]

Спасибо за напоминание, что "хэндл" живет в потоке, в котором он создан)) Но откуда следует, что остановить поток (quit) можно только из того потока, откуда он был запущен?

Это QObject, с которым могут связаны какие-нибудь сигналы, и слоты вызываются в основном потоке. Сама обертка QThread не помечена, как thread-safe, таким образом одновременный вызов методов из разных потоков может привести к плачевным результатам.

Иначе говоря, код

Код

C++ (Qt)
Worker::~Worker() {
    workerThread->quit();
    workerThread->deleteLater();
}
 

корректен?

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

[Igors]

Иначе говоря, код

Код

C++ (Qt)
Worker::~Worker() {
    workerThread->quit();
    workerThread->deleteLater();
}
 

корректен?

Это не так уж важно , плохо уже то что создается почва для (ненужных) раздумий. Вызов quit останавливает loop нитки, но нитка еще не завершилась.

Since Qt 4.8, if deleteLater() is called on an object that lives in a thread with no running event loop, the object will be destroyed when the thread finishes.

Т.е. если вызов был из workerThread - сработает. А вот из др - хз. Напр вызывающий вытеснен между quit и deleteLater, а когда проснулся - нитка уже завершена  

Edit: а, так из другой дкструктор вызваться и не сможет