QThread Опции

[gpepsi]

потоковая функция крутит постоянный цикл опрашивая флаг завершения.
функция ожидания потока (wait) может ждать его бесконечно.

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

как это можно реализовать ? или нужно писать обертку ?

[PAFOS]

Если я правильно понял, то можно сделать так:


while( !thread->wait(100) ){
тут можно сбрасывать флаг, когда нужно
}

Сообщение отредактировал PAFOS - 5.8.2011, 13:33

[gpepsi]

Если я правильно понял, то можно сделать так:


while( !thread->wait(100) ){
тут можно сбрасывать флаг, когда нужно
}

немного не так. поток крутится

while(flag)
{
}

а сбросить флаг нет возможности. поэтому wait() будет блокирующий до бесконечности

[PAFOS]

там же у функции bool QThread::wait( int usec ) можно явно задать кол-во миллисекунд ожидания. Если по истечении времени поток завершился, то bool QThread::wait( int usec ) вернет true, иначе false.

[gpepsi]

там же у функции bool QThread::wait( int usec ) можно явно задать кол-во миллисекунд ожидания. Если по истечении времени поток завершился, то bool QThread::wait( int usec ) вернет true, иначе false.

это понятно - но в моем случае wait никогда не завершится с true. Это значит, что поток нужно terminate, что не есть хорошо

[wiz29]

там же у функции bool QThread::wait( int usec ) можно явно задать кол-во миллисекунд ожидания. Если по истечении времени поток завершился, то bool QThread::wait( int usec ) вернет true, иначе false.

это понятно - но в моем случае wait никогда не завершится с true. Это значит, что поток нужно terminate, что не есть хорошо

Используй петлю обработки сообщений в рамках потока и QEvent смотреть тут как это работает

[PAFOS]

Походу чет мы недопонимаем.

Может быть по коду будет понятнее моя мысль:

#include <QtCore>


class Thread : public QThread
{
    QAtomicInt m_terminateFlag; // Позволяет атомарно работать с целочисленной переменной 
    int m_counter; // полезный результат выполнения потока

    void run()
    {
        qDebug() << "Thread started";
        
        // ожидаем пока главный поток не поставит флаг завершения
        while( m_terminateFlag == 0 )
        {
            // выполняем полезную нагрузку
            m_counter++;
        }
        
        qDebug() << "Thread ended";
    }

public:
    Thread():QThread(),m_terminateFlag(false),m_counter(0){}

    int counter() const
    {return m_counter;}

    void setTerminateFlag()
    { m_terminateFlag = 1; }

};

int main(int argc, char *argv[])
{
    const int WorkInSeconds = 10;

    QCoreApplication a(argc, argv);

    Thread thread;
    thread.start();

    QTime time;
    time.start();

    // Ожидаем пока поток завершится самостоятельно
    while( !thread.wait(10) )
    {
        // Проверяем условие завершения потока и ставим дочернему потоку флаг завершения  
        if( (time.elapsed()/1000) > WorkInSeconds )
            thread.setTerminateFlag();
        

        QCoreApplication::processEvents();
    }

    qDebug() << thread.counter();

    return 0;
}

Не покатит?)

И кстати, тему бы переместить не помешало бы)