Как завершить поток таймера?

[Bepec]

Вы правы, после запуска потока deleteLater просто не работает.
Видимо у него нет критериев для QThread, по которым он может освободить объект. Что весьма странно, ведь в старых версиях утечек памяти у меня не было.
Зато простой delete работает на отлично.

Нашёл в исходниках вот такую строчечку

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.

и вот такую

 From Qt 4.8 onwards, it is possible to deallocate objects that
    live in a thread that has just ended, by connecting the
    finished() signal to QObject::deleteLater().

Могу ошибаться, но получается из 1 цитаты, что объект потока удалится лишь после окончания работы потока, в которым был вызван ( основного потока).
А из второй безболезненное решение - вешать finished на deleteLater QObject'ов, которые живут в потоке, в том числе и таймеров.

PS но вопрос открыт - как же не "ручным" способом удалять поток

[Bepec]

Пока у меня только вариант вешать на finished потока слот с delete sender'a.

[demaker]

Ответ = вызов в нём deleteLater и quit.

Предположим, что deleteLater() для экземпляра thread отработал, это значит еще не был завершен его метод run() и exec() в другом потоке, что может быть чревато последствиями - QThread: Destroyed while thread is still running и все что описано ранее в примере 1.
Если же сначала завершить поток, а затем вызвать deleteLater(), то экземпляр thread не будет удален совсем - утечки памяти.

Простой пример

Код

C++ (Qt)
class Thread
: public QThread
{
public:
    ~Thread ()
    {
        ::std::cout << "Deleted" << ::std::endl;
    }
 
    virtual void run ()
    {
        ::std::cout << "Before exec" << ::std::endl;
        exec();
        ::std::cout << "After exec" << ::std::endl;
    }
};
 
int main ( int argc, char ** argv )
{
    QCoreApplication app( argc, argv );
 
    QThread * thread = new Thread;
    thread->moveToThread( thread );
    thread->start();
    thread->deleteLater();
    thread->quit();
 
    return app.exec();
}
 

выводит только

Код:

Before exec
After exec

либо, если между deleteLater() и quit() будет достаточно времени (например, пауза или логика какая)

Код:

Before exec
Deleted
QThread: Destroyed while thread is still running
After exec

Поправьте меня - возможно я не прав, но
возможно так лучше будет

Код

C++ (Qt)
thread->quit();
thread->wait();
delete thread;
 

И тогда вот этого не будет

Код:

QThread: Destroyed while thread is still running

[Kurles]

По мне дык наследование от QThread и переопределение в нем метода run() не очень хорошая практика. Использую механизм "воркеров", как то всё прозрачней получается, и проще следить за временем жизни объектов. Вот синтетический пример:

Код

C++ (Qt)
#include <QCoreApplication>
#include <QThread>
#include <QTimer>
#include <QDebug>
 
class Worker : public QObject {
    Q_OBJECT
public:
    Worker(QObject *parent = 0) : QObject(parent), mTimer(0) {}
    ~Worker() { qDebug() << Q_FUNC_INFO; }
 
    Q_INVOKABLE void start() {
        // для того, что бы создать таймер в контексте потока, в который перемещён
        // воркер, используем QMetaObject::invokeMethod
        if (QThread::currentThread() != thread()) {
            QMetaObject::invokeMethod(this, "start", Qt::QueuedConnection);
            return;
        }
        mTimer = new QTimer(this);
        connect(mTimer, &QTimer::timeout,
                this, &Worker::onTimeout);
        mTimer->start(1000);
    }
 
signals:
    void timeout();
 
private:
    void onTimeout() {
        qDebug() << "worker" << QThread::currentThreadId();
        emit timeout();
    }
 
private:
    QTimer *mTimer;
 
};
 
class Test : public QObject
{
    Q_OBJECT
public:
    Test(QObject *parent = 0) :
        QObject(parent),
    mWorker(new Worker())
    {
    connect(mWorker, &Worker::timeout,
            this, &Test::onTimeout,
            Qt::QueuedConnection);
    }
    ~Test()
    {
        // планируем удаление воркера
        mWorker->deleteLater();
        if (mThread.isRunning()) {
            // рубим поток
            mThread.quit();
            // даём время уничтожится воркеру
            mThread.wait();
        }
        qDebug() << Q_FUNC_INFO;
    }
 
    void start() {
        // перемещаем воркер в отдельный поток
        mWorker->moveToThread(&mThread);
        // стратуем поток
        mThread.start();
        // и воркер
        mWorker->start();
        // планируем через 5 секунд выход из тестового приложения
        QTimer::singleShot(5000, this, &Test::onQuitTimeout);
    }
 
 
    void onTimeout() {
        qDebug() << "test" << QThread::currentThreadId();
    }
 
    void onQuitTimeout() {
        qApp->quit();
    }
 
private:
    QThread mThread;
    Worker *mWorker;
 
};
 
int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);
 
    Test t;
    t.start();
 
    return a.exec();
}
 
#include "main.moc"
 
 

[ssoft]

Здесь смущает только место использования

Код

C++ (Qt)
mWorker->deleteLater();
 

Если поток уже завершен, то event loop уже остановлена и некому выполнять deleteLater).
А так, использование Worker в разных вариациях предпочтительнее. Наследование от потока тоже корректно, здесь на вкус и цвет, кому как удобнее.

[ssoft]

Поправьте меня - возможно я не прав, но
возможно так лучше будет

Код

C++ (Qt)
thread->quit();
thread->wait();
delete thread;
 

И тогда вот этого не будет

Код:

QThread: Destroyed while thread is still running

Так тоже будет корректно, но тогда уж лучше сразу переменную на стеке делать и не мучаться с new/delete.

[Kurles]

Здесь смущает только место использования

Код

C++ (Qt)
mWorker->deleteLater();
 

Если поток уже завершен, то event loop уже остановлена и некому выполнять deleteLater).
А так, использование Worker в разных вариациях предпочтительнее. Наследование от потока тоже корректно, здесь на вкус и цвет, кому как удобнее.

Поток останавливается ниже в деструкторе. Вызов QThread::quit и последующий вызов QThread::wait() гарантирует как минимум еще одну итерацию event loop потока, которая в свою очередь обеспечит удаление все запланированных к удалению объектов, привязанных к данному потоку.

[Old]

последующий вызов QThread::wait() гарантирует как минимум еще одну итерацию event loop потока

wait ничего не гарантирует, даже более он сам блокирует поток в котором запущен до завершения ожидаемой нитки. В это время eventloop не крутиться.

[Kurles]

последующий вызов QThread::wait() гарантирует как минимум еще одну итерацию event loop потока

wait ничего не гарантирует, даже более он сам блокирует поток в котором запущен до завершения ожидаемой нитки. В это время eventloop не крутиться.

то есть связка последовательных вызовов QThread::quit + QThread::wait не гарантирует итерации eventLoop'а? Как тогда корректно завершить поток с удалением всех его children'ов?

[demaker]

последующий вызов QThread::wait() гарантирует как минимум еще одну итерацию event loop потока

wait ничего не гарантирует, даже более он сам блокирует поток в котором запущен до завершения ожидаемой нитки. В это время eventloop не крутиться.

Т.е Вы хотите сказать тем самым, что в книге Боровский А.Н. Qt 4.7+ Практическое программирование на С++ (2012г.) стр 169 Листинг 5.3 (глава 5) НЕ ВЕРЕН И В НЕМ ОШИБКА.

[demaker]

Поправьте меня - возможно я не прав, но
возможно так лучше будет

Код

C++ (Qt)
thread->quit();
thread->wait();
delete thread;
 

И тогда вот этого не будет

Код:

QThread: Destroyed while thread is still running

Так тоже будет корректно, но тогда уж лучше сразу переменную на стеке делать и не мучаться с new/delete.

Вы имейти  ввиду переменную на стеке - т.е в run

[kuzulis]

Wait не нужен если используется концепция с worker-ами, достаточно только quit(). Все там удалится как надо (если были коннекты к deleteLater() у воркета и у треда).

[Old]

то есть связка последовательных вызовов QThread::quit + QThread::wait не гарантирует итерации eventLoop'а?

Ну откройте уже исходники.

wait блокирует выполнения нитки в котором он вызван, до завершения ожидаемой нитки.

Код

C++ (Qt)
bool QThread::wait(unsigned long time)
{
    Q_D(QThread);
    QMutexLocker locker(&d->mutex);
 
    if (d->thread_id == pthread_self()) {
        qWarning("QThread::wait: Thread tried to wait on itself");
        return false;
    }
 
    if (d->finished || !d->running)
        return true;
 
    while (d->running) {
        if (!d->thread_done.wait(locker.mutex(), time))
            return false;
    }
    return true;
}
 

[Old]

Т.е Вы хотите сказать тем самым, что в книге Боровский А.Н. Qt 4.7+ Практическое программирование на С++ (2012г.) стр 169 Листинг 5.3 (глава 5) НЕ ВЕРЕН И В НЕМ ОШИБКА.

Честно говоря, я понятия не имею, что там написано.
Легко может быть ошибка.

[ssoft]

Вы имейти  ввиду переменную на стеке - т.е в run

Я имею в виду такие костыли).

Код

C++ (Qt)
MyThread thread;
thread.moveToThread( &thread );
thread.start();
...
thread.quit();
thread.wait();
 

или даже такие

Код

C++ (Qt)
class MyThread : public QThread
{
public:
    MyThread ()
    {
        moveToThread( this );
    }
 
    ~MyThread ()
    {
        quit();
        wait();
    }
...
};
 
MyThread thread;
thread.start();
...
 

А по хорошему используйте QtConcurrent.

Wait не нужен если используется концепция с worker-ами, достаточно только quit(). Все там удалится как надо (если были коннекты к deleteLater() у воркета и у треда).

По-моему это уже обсуждали http://www.prog.org.ru/index.php?topic=31557.msg233459#msg233459 или что-то другое имеется в виду?