Qt Wątki - przerwanie :: 4programmers.net

mto9

2012-02-03T18:10:28+01:00

Rejestracja: dni
Ostatnio: dni
Postów: 380

0

Witam.
Mam do napisania aplikacje która wykorzystuje wątki w GUI, po przeczytaniu kilku poradników mam:

główne okno z przyciskami START i ANULUJ, które zawiera wskaźnik do QThread i myClass w konstruktorze robię coś takiego:

Kopiuj

myClass = new mClass;
cThread = new QThread;

connect(myClass,SIGNAL(wypisz1()),this,SLOT(wypisz1()));
connect(myClass,SIGNAL(wypisz2()),this,SLOT(wypisz2()));

myClass->DoSetup(cThread);
myClass->moveToThread(cThread);

Klikając start uruchamiam wątek: cThread->start()

-Klase myClass która wygląda tak:

Kopiuj

void myClass::DoSetup(QThread *cThread)
{
    connect(cThread,SIGNAL(started()),this,SLOT(DoWork()));
}

void myClass::DoWork()
{
    // tu instrukcje dla wątku 
}

No i nie wiem jak zrobić aby ANULUJ działało jak powinno... próbowałem na wiele sposobów ale kończą się one:
QThread: Destroyed while thread is still running

ANULUJ na przerwać prace wątku i go zniczyć... Prosze o pomoc :)

MasterBLB

2012-02-03T18:30:03+01:00

Rejestracja: dni
Ostatnio: dni
Lokalizacja: Warszawa
Postów: 1454

0

Źle używasz,przeczytaj dokumentację od klasy QThread jak się nią posługuje (rodzi mi o reimplementację run-a)
A zakończenie to Qthread::exit()

mto9

2012-02-03T18:42:13+01:00

Rejestracja: dni
Ostatnio: dni
Postów: 380

0

No właśnie przeczytałem 3 tony dokumentacji i wyczytałem, że zalecane jest używanie wątków właśnie w taki sposób tu link: http://developer.qt.nokia.com/doc/qt-4.8/qthread.html#started na samym końcu...

mto9

2012-02-03T19:18:32+01:00

Rejestracja: dni
Ostatnio: dni
Postów: 380

0

Zmieniłem kod na to z funkcją ran i w sytuacji gdy kliknę szybko start potem anuluj i zamkne dialog w którym uruchamiam wątek (powrót do głownego okna programu) znowu wyskakuje: QThread: Destroyed while thread is still running ..

MasterBLB

2012-02-03T19:26:01+01:00

Rejestracja: dni
Ostatnio: dni
Lokalizacja: Warszawa
Postów: 1454

0

Hmm...zapodaj projekt

mto9

2012-02-03T19:35:08+01:00

Rejestracja: dni
Ostatnio: dni
Postów: 380

0

Dialog uruchamiany przy pomocy przycisku z okna głównego:
dialog_send.h

Kopiuj

#ifndef DIALOG_SEND_H
#define DIALOG_SEND_H

#include <QDialog>
#include <wiadomosc.h>
#include <startsend.h>

namespace Ui {
    class Dialog_Send;
}

class Dialog_Send : public QDialog
{
    Q_OBJECT

public:
    explicit Dialog_Send(wiadomosc *Wiadomosc,QWidget *parent = 0);
    ~Dialog_Send();

    void PrzedSend();

private slots:
    void on_pushButton_clicked();
    void slo_connect();
    void slo_not_connect();


private:
    Ui::Dialog_Send *ui;
    bool OK_adres(QString &adres);

    wiadomosc *myWiadomosc;
    StartSend *cStartSend;
};

#endif // DIALOG_SEND_H

dialog_send.cpp

Kopiuj


#include "dialog_send.h"
#include "ui_dialog_send.h"

Dialog_Send::Dialog_Send(wiadomosc *Wiadomosc,QWidget *parent) :
    QDialog(parent),
    ui(new Ui::Dialog_Send),
    myWiadomosc(Wiadomosc)
{
    ui->setupUi(this);

    ui->progressBar->setValue(0);

    cStartSend = new StartSend(myWiadomosc);

    connect(cStartSend,SIGNAL(sig_connect()),this,SLOT(slo_connect()));
    connect(cStartSend,SIGNAL(sig_not_connect()),this,SLOT(slo_not_connect()));

}

Dialog_Send::~Dialog_Send()
{
    delete this->cStartSend;
    delete ui;
}

void Dialog_Send::PrzedSend()
{
   // ...
       instrukcje sprawdzające poprawność adresów itp.
   // ...

    cStartSend->start(QThread::HighPriority);
}


bool Dialog_Send::OK_adres(QString &adres)
{
    // ...
}

void Dialog_Send::on_pushButton_clicked()
{
    if(ui->pushButton->text()=="Start")
    {
        ui->pushButton->setText("Anuluj");
        ui->pushButton_2->setEnabled(false);
        PrzedSend();
    }
    else
    {
        this->cStartSend->exit(-1);  //  czy tutaj ok?
        ui->pushButton->setEnabled(false);
        ui->plainTextEdit->appendPlainText("\nAnulowanie procedury wysyłania e-maili...");
        ui->pushButton_2->setEnabled(true);
    }
}

void Dialog_Send::slo_connect()
{
    ui->plainTextEdit->appendPlainText("[+] Nawiązano połączenie z serwerem SMTP!");
}

void Dialog_Send::slo_not_connect()
{
    ui->plainTextEdit->appendPlainText("[x] Nie można nawiązać połączenia z serwerem SMTP!\n      Przyczyną może być brak dostępu do Internetu lub źle skonfigurowane konto.");
    ui->pushButton->setText("Start");
    ui->pushButton_2->setEnabled(true);
}

startsend.h //watek

Kopiuj

#ifndef STARTSEND_H
#define STARTSEND_H

#include <QObject>
#include <QThread>
#include <QSslSocket>
#include <wiadomosc.h>

class StartSend : public QThread
{
    Q_OBJECT
public:
    explicit StartSend(wiadomosc *myWiadomosc,QThread *parent = 0);
    void run();

private:
    wiadomosc *myWiadomosc;

signals:
    void sig_connect();
    void sig_not_connect();
};

#endif // STARTSEND_H

startsend.cpp

Kopiuj


StartSend::StartSend(wiadomosc *Wiadomosc,QThread *parent) :
    QThread(parent),
    myWiadomosc(Wiadomosc)
{
}

void StartSend::run()
{
    //CONNECT
    bool Connect = false;
    QSslSocket mySocket;
    if((int)myWiadomosc->type_encryption == 0)
    {
        mySocket.connectToHost(myWiadomosc->smtp, myWiadomosc->port);
        if(mySocket.waitForConnected()) Connect = true;
    }
    else
    {
        if((int)myWiadomosc->type_encryption == 1) mySocket.setProtocol(QSsl::SslV3);
        mySocket.connectToHostEncrypted(myWiadomosc->smtp, myWiadomosc->port);
        if(mySocket.waitForConnected()) Connect = true;
    }

    if(!Connect)
    {
        this->sig_not_connect();
    }
    else
    {
        this->sig_connect();
    }

    while(true){};

    exec();
}