Qthread & сигналы Опции Подписка на тему Сообщить другу Версия для печати Скачать тему Подписка на этот форум Режимы отображения Переключить на: Древовидный Стандартный Переключить на: Линейный

[OrSOn]

Добрый день всем! Столкнулся со следующей проблемой... Есть программа, в которой нужно использовать потоки, причем основной поток должен обмениваться сигналами с вновь созданными. Так вот проблема примерно в следующем:

Попробовал просто все подключить коннектами, в результате thread принимает мои сигналы, но сам их испускать не может.
Попробовал в начале run() вписывать exec(), в результате до нужного участка кода, разумеется, поток не доходил
Попробовал способ с moveToThread(), сделал примерно следующее:

thread1 = new NThread(0);
thread1->moveToThread( thread1 );
connect(thread1, SIGNAL(endThreadSocket( PrioritySocket )), this, SLOT(socketToList( PrioritySocket )));
connect(this, SIGNAL(setSocket1( PrioritySocket )), thread1, SLOT(setThreadSocket( PrioritySocket )));
thread1->start();

При этом поток вообще не видит испускаемых мной сигналов. Подскажите, пожалуйста, что именно делаю не так и как заставить все это дело нормально взаимодействовать.

[Andrewshkovskii]

У Саборга в блоге, что-то такого было, вроде это :
http://vingrad.ru/blogs/sabrog/2009/06/11/...d-myunhgauzena/

[OrSOn]

Увы, это не то( Там написано, что сигналы из run() нормально обрабатываются... А у меня основной поток их ВООБЩЕ не видит...

[BRE]

Увы, это не то( Там написано, что сигналы из run() нормально обрабатываются... А у меня основной поток их ВООБЩЕ не видит...

Так ты бы кода побольше показал... Что там в run у тебя, как отсылаешь, как принимаешь...

[OrSOn]

Ну внутри рана у меня следующее:

void NThread::run()
{
    while( !threadEnd )
    {    
        if( setSocketFlag )
        {
            setSocketFlag = false;
            setThreadSocketFn();
        }

        msleep( 100 );
    }
}

setSocketFlag у меня задается в слоте, который принимает сигнал от основного потока. Т.е. ран крутится, пока основной поток не передаст сигнал. Передал, попали в функцию setThreadSocketFn(). Внутри этой функции ведется некоторая обработка, после чего написано:

emit endThreadSocket( PrioritySocket );

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

Причина редактирования: используй тэг code

[BRE]

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

Набросал небольшой рабочий пример:

Раскрывающийся текст

#include <QApplication>          
#include <QThread>               
#include <QDebug>                

class Thread : public QThread
{                            
    Q_OBJECT                 
public:                      
    Thread() : QThread( 0 ) { moveToThread( this ); }

signals:
    void started();
    void stopped();

protected:
    void run()
    {         
        emit started();
        sleep( 2 );    
        emit stopped();
    }                  
};                     

class Recv : public QObject
{
    Q_OBJECT
public:
    Recv() : QObject( 0 ) {}

public slots:
    void threadStarted()
    {
        qDebug() << "Thread started.";
    }

    void threadStopped()
    {
        qDebug() << "Thread stopped.";
    }
};

int main(int argc, char *argv[])
{
    QCoreApplication app(argc, argv);

    Recv recv;
    Thread thread;

    QObject::connect( &thread, SIGNAL( started() ), &recv, SLOT( threadStarted() ) );
    QObject::connect( &thread, SIGNAL( stopped() ), &recv, SLOT( threadStopped() ) );

    thread.start();

    return app.exec();
}

#include "main.moc"

[OrSOn]

В том и проблема, что суть та же, но у меня не принимаются сигналы, хоть ты тресни...

[BRE]

Т.е. ран крутится, пока основной поток не передаст сигнал. Передал, попали в функцию setThreadSocketFn(). Внутри этой функции ведется некоторая обработка, после чего написано:

А в setThreadSocketFn точно попадаешь?

[OrSOn]

Да. Попробовал только что вообще просто все сделать... В своем основном потоке объявляю thread

thread1 = new NThread(this);
connect(thread1, SIGNAL(endThreadSocket( PrioritySocket )), this, SLOT(socketToList( PrioritySocket )));
connect(this, SIGNAL(setSocket1( PrioritySocket )), thread1, SLOT(setThreadSocket( PrioritySocket )));
thread1->start();

Т.е. ТОЛЬКО запустил конструктор и вошел в ран().

Ран описан очень просто:

void NThread::run()
{
   while( 1 > 0 )
   {    
      emit endThreadSocket( priorSocket );
      msleep( 100 );
   }
}

Так вот тот самый эмит он проходит непрерывно, но в слот socketToList( PrioritySocket ) упорно отказывается попадать. Причем если тот же сигнал испустить ВНЕ функции ран(), все отлично перехватывается...

[BRE]

Так вот тот самый эмит он проходит непрерывно, но в слот socketToList( PrioritySocket ) упорно отказывается попадать. Причем если тот же сигнал испустить ВНЕ функции ран(), все отлично перехватывается...

Очередь сообщений QApplication запущена?