Как запустить в Qt новый процесс (или поток) в виде функции?

[a_n_y_a]

А функция сигнал реализуется самой библиотекой?! Я думал, что я сам ее должен реализовывать. Так?

[lit-uriy]

Сигнал - чисто виртуальная функция (для програмиста), т.е. объявление без реализации. (Реализацией занимается moc - мета-объектный компилятор)

[a_n_y_a]

А какое должно быть соотношение параметров сигнала и слота? Параметры должны совпадать? Или возможно несовпадение?

[uriel]

Первые параметры сигнала должны совпадать с параметрами слота.
Например, может быть так:
Сигнал: (QString, QString) -> Слот: ()
() -> (int = 0)
(int, QString) -> (int)
А так быть не может:
()- > (int)
(QString) -> (int)
(QString, int) -> (int = 0)
P.S. Если где-то ошибся, поправьте, пожалуйста.

[a_n_y_a]

Есть такой код:
   Pt=new PotokThread((QObject*)this);
   QObject::connect(ui.MyRun, SIGNAL(clicked()),this, SLOT(ZapuskThread()));
Вопрос: когда поток закрыт по quit();, то Pt еще имеет смысл, или уже удаляется из памяти?

И можно ли по ходу программы создавать потоки и конекты с ними, а потом удалять конекты и потоки?

[spectre71]

Есть такой код:
   Pt=new PotokThread((QObject*)this);
   QObject::connect(ui.MyRun, SIGNAL(clicked()),this, SLOT(ZapuskThread()));
Вопрос: когда поток закрыт по quit();, то Pt еще имеет смысл, или уже удаляется из памяти?

И можно ли по ходу программы создавать потоки и конекты с ними, а потом удалять конекты и потоки?

1) Если сделать так

Код

C++ (Qt)
  Thread = new MyThread;
  connect(Thread , SIGNAL(finished()), Thread , SLOT(deleteLater()));
  Thread->start();

То, объект Thread удалиться сам по завершению потока.
Соответственно, после Thread->start() использовать объект Thread в главном потоке нельзя, поскольку неизвестно когда поток завершиться и объект Thread будет удален из памяти.

2)  Если сделать так

Код

C++ (Qt)
  Thread = new MyThread;
  connect(Thread , SIGNAL(finished()), MyWidget , SLOT(myThreadFinishedSlot()));
  Thread->start();

То, необходимо отследить момент завершения потока(SIGNAL(finished())) и самостоятельно удалить объект Thread.
Соответственно,  можно  использовать объект Thread в главном потоке до его самостоятельного удаления.
myThreadFinishedSlot - слот у MyWidget который необходимо определить чтобы отследить момент завершения потока.

[a_n_y_a]

Что то у меня работает, но не так. Есть:

Potok::Potok(QWidget *parent)
    : QWidget(parent)
{
   ui.setupUi(this);
   Pt=new PotokThread((QObject*)this);
   QObject::connect(ui.MyRun, SIGNAL(clicked()),this, SLOT(ZapuskThread()));
   connect(Pt , SIGNAL(finished()), Pt , SLOT(deleteLater()));
   QObject::connect(Pt, SIGNAL(valueChanged(int)), ui.Zapolnenie, SLOT(setValue(int)), Qt::QueuedConnection);
};

  Нажимаю на кнопку MyRun, начинается отсчет времени и отображение этого процесса на прогрессбаре ui.Zapolnenie,
по окончанию цикла, Pt не удаляется, но если я нажимаю на MyRun еще раз (после завершения цикла), то завершается вся программа без какого либо сообщения. Вопрос, почему?

[spectre71]

Что то у меня работает, но не так. Есть:

Potok::Potok(QWidget *parent)
    : QWidget(parent)
{
   ui.setupUi(this);
   Pt=new PotokThread((QObject*)this);
   QObject::connect(ui.MyRun, SIGNAL(clicked()),this, SLOT(ZapuskThread()));
   connect(Pt , SIGNAL(finished()), Pt , SLOT(deleteLater()));
   QObject::connect(Pt, SIGNAL(valueChanged(int)), ui.Zapolnenie, SLOT(setValue(int)), Qt::QueuedConnection);
};

  Нажимаю на кнопку MyRun, начинается отсчет времени и отображение этого процесса на прогрессбаре ui.Zapolnenie,
по окончанию цикла, Pt не удаляется, но если я нажимаю на MyRun еще раз (после завершения цикла), то завершается вся программа без какого либо сообщения. Вопрос, почему?

Pt=new PotokThread((QObject*)this); - создается  только 1 раз - в конструкторе! На deleteLater - объект Pt уничтожается. После уничтожения Pt - вызов Pt->start() приводит к ошибке!
Делать надо так:

Код

C++ (Qt)
Potok::Potok(QWidget *parent)
    : QWidget(parent)
{
	ui.setupUi(this);
	QObject::connect(ui.MyRun, SIGNAL(clicked()),this, SLOT(ZapuskThread()));
};
 
void Potok::ZapuskThread (void) {
	Pt=new PotokThread((QObject*)this);
	connect(Pt , SIGNAL(finished()), Pt , SLOT(deleteLater()));
	QObject::connect(Pt, SIGNAL(valueChanged(int)), ui.Zapolnenie, SLOT(setValue(int)), Qt::QueuedConnection);
        Pt->start();
}
 

[a_n_y_a]

Да, действительно в Pt дело! А почему мне не было выдано сообщение об ошибке указателя? Программа просто завершалась. Я работаю в Eclipse, может в ней дело?

[a_n_y_a]

Запускаю поток, идет отсчет времени и отображение процесса в прогрессбаре.
Жму крестик - завершение программы, мне выдается сообщение:
QThread: Destroyed while thread is still running
Так и должно быть? Или надо как то обрабатывать поток и завершать его?

[pastor]

Так и должно быть? Или надо как то обрабатывать поток и завершать его?

Такого недолжно быть. Нужно корректно завершать работу потока(ов).

Покажи код деструктора потока.

[a_n_y_a]

В потоке деструктор пустой, ничего не делает.

[pastor]

Покажи тогда метод run()

[a_n_y_a]

Покажи тогда метод run()

Вот:
PotokThread::~PotokThread()
{
   // TODO Auto-generated destructor stub
};

void PotokThread::run()
{
   // TODO Auto-generated destructor stub
   int i;
   for(i=100;i>=0;i--)
   {
      msleep(100);
      emit valueChanged(i);
   };
};

[pastor]

Попробуй например так:

Код

C++ (Qt)
class PotokThread : public QThread
{
    Q_OBJECT
....
public slots:
    void exitThread();
 
private:
    QMutex m_stopMutex;
    bool m_stopped;
};
 
 
 
PotokThread::~PotokThread()
{
	exitThread();
};
 
void PotokThread::exitThread()
{
	if (!isRunning())
		return;	
	m_stopMutex.lock();
        m_stopped = true;
        m_stopMutex.unlock();
	wait();
} 
 
void PotokThread::run()
{
    m_stopMutex.lock();
    m_stopped = false;
    m_stopMutex.unlock();
 
   for(int i=100;i>=0 && !m_stopped;--i)
   {
      msleep(100);
      emit valueChanged(i);
   };
};