Потоки

[demaker]

Есть простейшая программа обработки портов

Код

C++ (Qt)
Thread::Thread(QObject * parent): QThread(parent)
{
}
 
Thread::~Thread()
{
 qDebug()<<__FUNCTIOIN__;
}
 
void Thread::run()
{
    while(1)
    {
        msleep(3);
        handlePress();        
    }
}
 
void Thread::handlePress()
{
 
 // опрос портов
}
 
 
 
MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow)
{
    ui->setupUi(this);    
 
    counter = 0;
    thread = NULL;
 
    if(initNumberLineGPIO() && initDirectionLineGPIO())
    {
        thread = new Thread();
        thread->start();
    }
}
 
MainWindow::~MainWindow()
{
    delete ui;
 
    if(thread != NULL){
      thread->quit();
      thread->wait();
      delete thread;
   }
}
 

Но выдается ошибка

Код:

QThread: Destroyed while thread is still running

хотя в деструктор Thread заходит, но сам процесс не убивается
не могу понять почему???

[Old]

Потому, что quit завершает цикл обработки событий потока, а вы его даже не запускаете.
Добавляйте свой флажок завершения бесконечного цикла в run.

[demaker]

Ожидал такого ответа.
Ну если правильно понял Вас )

делаю так

Код

C++ (Qt)
 
Thread::Thread(QObject * parent): QThread(parent)
{
  flag = true;
}
 
void Thread::run()
{
    while(flag)
    {
        msleep(3);
        handlePress();        
    }
}
 
 
MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow)
{
    ui->setupUi(this);    
 
    counter = 0;
    thread = NULL;
 
    if(initNumberLineGPIO() && initDirectionLineGPIO())
    {
        thread = new Thread();
        thread->start();
    }
}
 
MainWindow::~MainWindow()
{
    delete ui;
 
    if(thread != NULL){
      flag = false;
      thread->quit();
      thread->wait();
      delete thread;
   }
}
 

но выдается все таже ошибка

Код:

QThread: Destroyed while thread is still running

[Old]

Лучше flag сделать членом Thread и quit можно не вызывать.

[demaker]

))
И так делал как Вы сказали
Вот код

Код

C++ (Qt)
class Thread: public QThread{
 
public:
 bool flag;
}
 
Thread::Thread(QObject * parent): QThread(parent)
{
  flag = true;
}
 
void Thread::run()
{
    while(flag)
    {
        msleep(3);
        handlePress();        
    }
}
 
 
MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow)
{
    ui->setupUi(this);    
 
    counter = 0;
    thread = NULL;
 
    if(initNumberLineGPIO() && initDirectionLineGPIO())
    {
        thread = new Thread();
        thread->start();
    }
}
 
MainWindow::~MainWindow()
{
    delete ui;
 
    if(thread != NULL){
      thread->flag = false;
      delete thread;
   }
}
 

Но не помогает ((

[Old]

Код

C++ (Qt)
MainWindow::~MainWindow()
{
    delete ui;
 
    if(thread != NULL){
      thread->flag = false;
      thread->wait();                        // !!! wait нужен
      delete thread;
   }
}
 

И что находится в handlePress?

[demaker]

Да конечно Вы правы!
Не убрал))
wait()

Код

C++ (Qt)
#define CNT_SAMPLE_MAX 4
#define CNT_SAMPLE_MIN 0
#define MAX_LINE_EVENT 10
 
typedef struct{
    int cnt_sample;//schetchik viborki
    int cnt_event_up; //schetchik sobitii
    int cnt_event_down;
    bool flag;
}gpio_line;
 

Код

C++ (Qt)
int number_gpio_line[amount_line] = {416,417,418,419,
                                     420,421,422,423,
                                     424,425,426,427,
                                     428,429,430,431,
                                     433,
                                     435,
                                     436
                                    };
 
 
gpio_line array_gpio_line[amount_line] = {{0,0,0,false},{0,0,0,false},{0,0,0,false},{0,0,0,false},
                                          {0,0,0,false},{0,0,0,false},{0,0,0,false},{0,0,0,false},
                                          {0,0,0,false},{0,0,0,false},{0,0,0,false},{0,0,0,false},
                                          {0,0,0,false},{0,0,0,false},{0,0,0,false},{0,0,0,false},
                                          {0,0,0,false},
                                          {0,0,0,false},
                                          {0,0,0,false}
                                         };
 
 

Код

C++ (Qt)
void Thread::handlePress()
{    
    for(int i = 0; i < amount_line; i++){
        QFile file;
        QDir::setCurrent("/sys/class/gpio/gpio" + QVariant(number_gpio_line[i]).toString());
        file.setFileName("value");
 
        if(file.open(QIODevice::ReadOnly)){
            QByteArray ba;
            ba = file.readAll();
            if(ba.at(0) == '1'){
                if(array_gpio_line[i].cnt_sample < CNT_SAMPLE_MAX){
                    array_gpio_line[i].cnt_sample++;
                }
                else if(!array_gpio_line[i].flag){
                    array_gpio_line[i].flag = true;
                    if( array_gpio_line[i].cnt_event_up < MAX_LINE_EVENT){//security counter
                        array_gpio_line[i].cnt_event_up++;
                    }
                }
            }
            else{
                if(array_gpio_line[i].cnt_sample > CNT_SAMPLE_MIN){
                    array_gpio_line[i].cnt_sample--;
                }
                else if(array_gpio_line[i].flag){
                    array_gpio_line[i].flag = false;
                    if( array_gpio_line[i].cnt_event_down < MAX_LINE_EVENT){//security counter
                        array_gpio_line[i].cnt_event_down++;
                    }
                }
            }
            file.close();
        }
        else{
            qDebug("file is not open");
        }
    }
}
 

Но к сожалению  в консоль выводится что программа завершилась
это уже лучше)))

но КРАХОМ ((
 

[Old]

И еще вопрос. Вы уверены, что это сообщение выдается при разрушении именно этой нитки? Может есть другие?
Попробуйте за комментировать создание этой нитки - останется сообщение или нет?

[demaker]

Ну я только создаю только одну нитку - Thread. Конечно есть main ))

Давайте я скину проект)
Так будет проще

[Old]

ok

[PimenS]

while(flag)
    {
        msleep(3);
        handlePress();        
    }

это так и задумано, чтобы handlePress() выполнялся бесконечно?

[demaker]

 

[Old]

Добавьте в конструкторе MainWindow инициализацию thread:

Код

C++ (Qt)
MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
	ui(new Ui::MainWindow),
	thread( 0 )
{
...
}
 

А в деструктор код завершения нитки.

[demaker]

А что
такая запись не катит

Код

C++ (Qt)
thread = new Thread();
 

 

[Old]

А что
такая запись не катит

Код

C++ (Qt)
thread = new Thread();
 

 

А если
if(initNumberLineGPIO() && initDirectionLineGPIO())
вернет false?