Привет всем и снова вопрос про многопоточность, выкладываю исходный код тестового примера. И сразу к вопросу, есть код расчёта который работает в потоке мы можем его принудительно закрыть используя используя флаг stop по нажатию кнопки и в конце функции посылать сигнал emit finished() все работает. Но когда у нас в функции потока идет обращение к функции которая определена в dll которую мы воспринимаем как черный ящик, т.е в потоке идет обращение к ней, в её аргументы идут данные и внутри нее рассчитываются, в самой dll, то как же ее принудительно прервать и удалить поток? внутри нее нет флагов и сигналов о ее прерывании, она работает пока не досчитает. Считает внутри пару минут и мы ждем возвращающее значение и только по выходу из нее наш поток прерывается, а затем удаляется по нашему флагу и сигналу о завершении finished(). И повторюсь, так как прервать принудительно поток? даже если внутри функции dll еще идет расчёт, не дожидаясь возвращающего значения? выкладываю тестовый рабочий пример для ориентира.
worker.cpp
#include "worker.h"
#include <QDebug>
Worker::Worker(QObject *parent) : QObject(parent)
{
Stop = false;
temp = 0;
}
Worker::~Worker()
{
qDebug() << "destruction Thread";
}
void Worker::process()
{
Stop = false;
if(!Stop == true)
{
for (; temp <= 100000; temp++)
{
if(!Stop == true)
{
emit(sendNumber(temp));
qDebug() << temp;
// ЗДЕСЬ БУДЕТ ВЫЗЫВАТСЯ ФУНКЦИЯ ИЗ DLL
// в её аргументы будут поступать данные и внутри обрабатываться очень долго
// до 2-3 минут обработки и возвращать значения
// но нам нужно сразу ее прервать, даже если она еще внутри расчитывает
}
else
{
return;
}
}
}
emit finished(); // вызывается при завершении расчёта
}
void Worker::reciveBoolStop(bool Numb)
{
Stop = Numb;
qDebug() << "reciveBoolStop = " << Stop;
emit finished(); // вызывается при отмене расчёта
}
worker.h
#ifndef WORKER_H
#define WORKER_H
#include <QObject>
class Worker : public QObject
{
Q_OBJECT
public:
explicit Worker(QObject *parent = 0);
~Worker();
bool Stop;
int temp;
signals:
void finished();
//void error(QString err);
void sendNumber(int);
public slots:
void process();
void reciveBoolStop(bool Numb);
};
#endif // WORKER_H
mainwindow.cpp
#include "mainwindow.h"
#include "ui_mainwindow.h"
#include <QDebug>
#include <QtCore>
MainWindow::MainWindow(QWidget *parent) :
QMainWindow(parent),
ui(new Ui::MainWindow)
{
ui->setupUi(this);
connect(this->ui->pushButton_start, SIGNAL(clicked()), this, SLOT(startGUI()));
connect(this->ui->pushButton_stop, SIGNAL(clicked()), this, SLOT(stopGUI()));
}
MainWindow::~MainWindow()
{
delete ui;
}
void MainWindow::startGUI()
{
// Создание потока
QThread* thread = new QThread;
Worker* worker = new Worker();
// Передаем права владения "рабочим" классом, классу QThread.
worker->moveToThread(thread);
// Соединяем сигнал started потока, со слотом process "рабочего" класса, т.е. начинается выполнение нужной работы.
connect(thread, SIGNAL(started()), worker, SLOT(process()));
// Отображаем в главном потоке Gui, значения из вторичного потока
connect(worker, SIGNAL(sendNumber(int)), this, SLOT(LineEditUi(int)));
// Оповещаем поток, что нужно остановиться
connect(this, SIGNAL(sendNumberBoolStop(bool)), worker, SLOT(reciveBoolStop(bool)), Qt::DirectConnection);
// ВЫЗЫВАЕТ УТЕЧКУ ПАМЯТИ
//connect(worker, SIGNAL(finished()), thread, SLOT(quit()));
// По завершению выходим из потока, и удаляем рабочий класс
connect(worker, SIGNAL(destroyed(QObject*)), thread, SLOT(quit())); // ТАК ПРАВИЛЬНО
connect(worker, SIGNAL(finished()), worker, SLOT(deleteLater()));
// Удаляем поток, после выполнения операции
connect(thread, SIGNAL(finished()), thread, SLOT(deleteLater()));
thread->start();
}
void MainWindow::LineEditUi(int number)
{
ui->lineEdit->setText(QString::number(number));
}
void MainWindow::stopGUI()
{
Stop = true;
qDebug() << Stop;
sendNumberBoolStop(Stop);
qDebug() << "sendMumberBoolStop = " << Stop;
}
mainwindow.h
#ifndef MAINWINDOW_H
#define MAINWINDOW_H
#include <QMainWindow>
#include "worker.h"
namespace Ui {
class MainWindow;
}
class MainWindow : public QMainWindow
{
Q_OBJECT
public:
explicit MainWindow(QWidget *parent = 0);
~MainWindow();
bool Stop;
public slots:
void startGUI();
void stopGUI();
void LineEditUi(int number);
signals:
void sendNumberBoolStop(bool);
private:
Ui::MainWindow *ui;
};
#endif // MAINWINDOW_H
main.cpp
#include "mainwindow.h"
#include <QApplication>
int main(int argc, char *argv[])
{
QApplication a(argc, argv);
MainWindow w;
w.show();
return a.exec();
}