QTcpSocket внутри Qthread

[Buran]

Приветствую всех.
Есть вопрос по QThread.

Создаю примерно так:

Код:

MyThread : public QThread
{

	MyThread()
	{
	QTcpSocket socket = new QTcpSocket();
	......
	......
	......
	}


	void socketWrite(QByteArray str)
	{
	socket->write(str);
	}

}

Во время выполнения socket->write(str) выводит ошибку, что не может сделать, т.к. родительский и дочерний потоки - разные.
И действительно, this - показывает указывает на один thread, а socket->thread() - на другой.

Т.е. new QtcpSocket() создается в отдельном потоке. Наверное так и должно быть?

Вопрос: Как мне создать socket в моем потоке? Чтобы this и socket->thread() возвращали указатель на один и тот же thread?
Или может мне socket'у указать socket->MoveToThread(this) (это только идея).



UPD:
Прочитал, что можно вызвать в функции run(). Но теперь не приходит SIGNAL(readyRead()). Почему? Ведь очередь сообщений теперь в моем новом потоке, а не в основном.
Подскажите, пжл, чего я не догоняю?

[serg_hd]

UPD:
Прочитал, что можно вызвать в функции run(). Но теперь не приходит SIGNAL(readyRead()). Почему? Ведь очередь сообщений теперь в моем новом потоке, а не в основном.
Подскажите, пжл, чего я не догоняю?

потому что поток умирает вместе с объектами которые были в нём созданы. Поставь в run()'e exec(), и глуши его когда надо будет

[Buran]

UPD:
Прочитал, что можно вызвать в функции run(). Но теперь не приходит SIGNAL(readyRead()). Почему? Ведь очередь сообщений теперь в моем новом потоке, а не в основном.
Подскажите, пжл, чего я не догоняю?

потому что поток умирает вместе с объектами которые были в нём созданы. Поставь в run()'e exec(), и глуши его когда надо будет

Брррр....
У меня поток не умирает. Он работает, это легко подтверждается выполняемым в нем кодом. И emit слота же работает!

Не срабатывает сигнал:

Код:

class MyThread : public QThread
{

	MyThread()
	{
	}


	void run()
	{
	QTcpSocket* socket = new QTcpSocket();
	QObject::connect(socket, SIGNAL(readyRead()), this, SLOT(SockerRead()));
	}

}

Насколько я понимаю, это может быть только если:
а) умер socket. Но, socket есть, можно запросить на него указатель.;
б) что-то с очередью сообщений;

UPD:
Кажись exec() как раз очередь сообщений и запускает. Сейчас проверю....)

[BRE]

потому что поток умирает вместе с объектами которые были в нём созданы. Поставь в run()'e exec(), и глуши его когда надо будет

По умолчанию в QThread::run как раз один exec() и запускается.

[BRE]

Код

C++ (Qt)
class MyThread : public QThread
{
 
	MyThread()
	{
	}
 
 
	void run()
	{
	QTcpSocket* socket = new QTcpSocket();
	QObject::connect(socket, SIGNAL(readyRead()), this, SLOT(SockerRead()));
        exec();
	}
 
}

[Buran]

Код

C++ (Qt)
 
	void run()
	{
	QTcpSocket* socket = new QTcpSocket();
	QObject::connect(socket, SIGNAL(readyRead()), this, SLOT(SockerRead()));
        exec();
	}
 
}

Ура! Очередь сообщений заработала. Но вот выполнение потока остановилось.(

Если быть точным, то кроме связывания сигнала и слота в run() еще есть while(). Внутри которого идет постоянное выполнение кода.

И вот при exec() оно (выполнение кода в while()) останавливается.

Пока не очень понимаю почему.

[BRE]

Пока не очень понимаю почему.

Потому, что в exec() запускается бесконечный цикл обработки событий.
Ты должен определиться, что тебе нужно. Если нужна возможность получения сигналов, то нужен exec (точнее обработка событий) и тогда с выполнением другого кода в потоке нужно думать.
Расскажи, что ты хочешь обрабатывать в цикле while()?

[serg_hd]

Совершенно не понял фразы

По умолчанию в QThread::run как раз один exec() и запускается.

А это

Код

C++ (Qt)
class MyThread : public QThread
{
 
	MyThread()
	{
	}
 
 
	void run()
	{
	QTcpSocket* socket = new QTcpSocket();
	QObject::connect(socket, SIGNAL(readyRead()), this, SLOT(SockerRead()));
        exec();
	}
 
}

вообще-то и имел ввиду

[Buran]

Расскажи, что ты хочешь обрабатывать в цикле while()?

По событию socket, SIGNAL(readyRead()) происходит обработка сокета.
А в while постоянно мониторится RS-232. Т.к. в QextSerialPort нифига не работает сигнал readyRead() я его (RS) просматриваю вручную.

Данные в потоке кидаются между ними.

В принципе, в никсах, я могу это обойти привязавшись к файлу /dev/ttyS# и смотреть его notify(). Но тогда в винда (в случае чего) мне не светит.

[BRE]

По событию socket, SIGNAL(readyRead()) происходит обработка сокета.
А в while постоянно мониторится RS-232. Т.к. в QextSerialPort нифига не работает сигнал readyRead() я его (RS) просматриваю вручную.

Ты в одном потоке и RS-232 мониторишь и из сетки данные получаешь?

[Buran]

По событию socket, SIGNAL(readyRead()) происходит обработка сокета.
А в while постоянно мониторится RS-232. Т.к. в QextSerialPort нифига не работает сигнал readyRead() я его (RS) просматриваю вручную.

Ты в одном потоке и RS-232 мониторишь и из сетки данные получаешь?

Угу.

[serg_hd]

BRE, ну так что ты хотел сказать насчёт exec()?

[BRE]

BRE, ну так что ты хотел сказать насчёт exec()?

То, что если run() не переопределять, то там как раз exec() и запускается. А вот если переопределять, то его нужно вызывать явно или вызывать QThread::run():

Код

C++ (Qt)
void MyThread::run()
{
        QTcpSocket* socket = new QTcpSocket();
        QObject::connect(socket, SIGNAL(readyRead()), this, SLOT(SockerRead()));
	QThread::run();	// или exec()
}
 

[BRE]

Угу.

Можно запустить таймер в этом потоке и через заданный интервал проверять состояние порта или разнести получение данных из сети и проверку порта по разным потокам.

[serg_hd]

[То, что если run() не переопределять, то там как раз exec() и запускается. А вот если переопределять, то его нужно вызывать явно или вызывать QThread::run():

Код

C++ (Qt)
void MyThread::run()
{
        QTcpSocket* socket = new QTcpSocket();
        QObject::connect(socket, SIGNAL(readyRead()), this, SLOT(SockerRead()));
	QThread::run();	// или exec()
}
 

ну естесственно его надо было переопределить, как же без этого-то! Какой смысл в потоке, если сам run() будет пустым))