QThread и бесконечный цикл в потоке

[titan83]

Здравствуйте.
Попользовался и гуглом, и местным поиском, но так и не решил свою проблему, поэтому пишу.
Есть поток, в котором вызывается poll() для контроля файлов на sysfs, это поток оформлен в виде бесконечного цикла, и именно его зацикленность порождает сообщение - QThread: Destroyed while thread is still running, но сообщение бы можно было игнорировать, а вот процесс-зомби уже мешает - приложение после этого повторно не запускается - завершается с кодом 0 на функции QThread::start().
Возможно, что я действую идеологически неправильно, тогда было бы здорово получить пинок в нужное направление.
Спасибо.
Привожу основные моменты кода:

class QMyObject: public QObject
{
Q_OBJECT

public slots:
    void getKey(int keyCode)
    {
        if (keyCode == -1)
        {
            emit exit();
        }
    }
signals:
    void exit(void);

};

class PollThread : public QThread
{
Q_OBJECT

private:

public:
    void run()
    {
        while(true)
        {
            poll(fdset, 2, 500);

            if (fdset[1].revents & POLLPRI)
            {
                switch (rx[0])
                {
                } /* switch (rx[0]) */

                emit keyPressed(keyCode);
            } /* if (fdset[0].revents & POLLPRI) */
        } /* while(true) */
    } /* void run() */

signals:
    void keyPressed(int);
};

int main(int argc, char *argv[])
{
    QApplication a(argc, argv);
    PollThread keyb_thread;
    QMyObject myObject;

    QObject::connect(&keyb_thread, SIGNAL(keyPressed(int)), &tabWidget, SLOT(setCurrentIndex(int)));
    QObject::connect(&keyb_thread, SIGNAL(keyPressed(int)), &myObject, SLOT(getKey(int)));
    QObject::connect(&keyb_thread, SIGNAL(finished()), &myObject, SLOT(deleteLater()));
    QObject::connect(&myObject, SIGNAL(exit()), &a, SLOT(closeAllWindows()));

    keyb_thread.start();

    return a.exec();
}

[mutineer]

Завершай поток перед тем, как уничтожать связанный с ним QThread. Например заведи volatile переменную и проверяй ее на каждой итерации цикла.

[titan83]

Завершай поток перед тем, как уничтожать связанный с ним QThread. Например заведи volatile переменную и проверяй ее на каждой итерации цикла.

Спасибо. Как я понимаю - это обычный return?
Надеялся, что без это удастся обойтись.

[mutineer]

Да, надо выйти из run()

Ну и перед удалением QThread подождать его при помощи wait()

[kuzulis]

a select() вместо poll() может спасти отца русской демократии?

[mutineer]

А чем оно поможет? Разве select неблокирующий?

[kuzulis]

А тем, что можно убрать QThread и использовать QSocketNotifier

[mutineer]

Извини, но я не вижу связи между заменой poll() на select() и заменой всего этого на QSocketNotifier. Можешь пояснить?

[kuzulis]

Код

C++ (Qt)
 
QSocketNotifier sysfsNotifier(ourWatchedSysfsDescriptor);
 
connect(sysfsNotifier, SIGNAL(activated(int)), this, SLOT(onActivated(int)));
sysfsNotifier.setEnabled(true);
 
 
MyClass::onActivated(int)
{
    // do something
}
 
 

[mutineer]

А где тут замена poll на select?

[kuzulis]

Эмм.. QSocketNotifier использует select() если не ошибаюсь. Поэтому, если ТС-у можно заменить poll() на select(), то можно заменить весь его Thread на QSocketNotifier (или на несколько ) и не парить мосг.

Т.е. следить за дескриптором в *nix (за евентами типа read/write/error) достаточно при помощи QSocketNotifier.

[titan83]

Эмм.. QSocketNotifier использует select() если не ошибаюсь. Поэтому, если ТС-у можно заменить poll() на select(), то можно заменить весь его Thread на QSocketNotifier (или на несколько ) и не парить мосг.

Т.е. следить за дескриптором в *nix (за евентами типа read/write/error) достаточно при помощи QSocketNotifier.

Денис, спасибо! То, что надо!
А то FileWatcher базируется на inotify, о она события на sysfs не ловит(

[titan83]

Хм, а у меня получить адекватную работу QSocketNotifier пока не получилось(
В слоте от нотифера я вычитываю данные из наблюдаемого файла, как я это делал раньше с select(), при этом удается прочесть адекватные данные только один раз, потом read() всегда возвращает число считанных байт ноль. Пробовал вычитывать и ReadAll() и просто read() из stdio - результат одинаковый. А раз я не вычитываю, то у меня сыплются постоянные прерывания от нотифера. Может есть пример заведомо рабочего кода?
Спасибо.

[kuzulis]

Покажи твой код с QSocketNotifier.

[titan83]

Тут проблема не в нотифире, видимо. Делаю просто

            file = open("/test", O_RDWR | O_NONBLOCK);

            while(true)
            {
                read(file, &c, 1);
                qDebug() << QString::number(c);
                read(file, &c, 1);
                qDebug() << QString::number(c);
            }
Файл содержит два байта - 52 и 10.
В первой итерации цикла все читается правильно, потом оба байта читаются как 10.
Посмотрел свои проекты на чистом си - там все аналогично происходит с select() и все работает.