Russian Qt Forum

Здравствуйте.
Возникла сложность при использовании QUdpSocket.
В приложении 3 потока:
1) поток, в котором выполняется функция main;
2) поток (унаследован от QThread), отправляющий данные через QUdpSocket;
3) поток (унаследован от QThread), принимающий данные через QUdpSocket.

При записи данных из потока main все замечательно: данные отправляются без ошибки, ответ приходит. При попытке отправки данных из 2го потока (даже если выполнять точно такие же действия, что в main-потоке) происходит ошибка (функция QUdpSocket::writeDatagram возвращает -1).

Действия выполняю следующие:

void CThread::f()
{
     QUdpSocket* udpSocket = new QUdpSocket();
     udpSocket->bind(QHostAddress::LocalHost, 7755);
     QByteArray ba = new QByteArray("asdf");
     udpSocket->writeDatagram(ba,QHostAddress::LocalHost,7756);     
}

С протоколом UDP я работаю первый раз, прошу сильно не ругаться ;) Подскажите, пожалуйста, в чем дело и как исправить?

может быть свзяно с этим ?:
Reentrancy and Thread-Safety:

Вы с одним объектом работаете из разных потоков? и как с данными?

Хотелось бы увидеть как выглядит весь класс CThread и как запускается этот поток.

То, что класс QUdpSocket - не ThreadSafe - это я знаю, но это имело бы значение, если бы я использовал один и тот же сокет в разных потоках или одни и те же данные. Однако, ошибка возникает даже при создании сокета и нахождении данных в экземпляре потока CThread.

Выложить полностью класс CThread возможности, к сожалению, нет.

Секретная разработка? ;D

Ладно, а откуда вызывается метод f()?

Метод f вызывается из метода run потока CThread

Наверно проще будет просто кусок кода.
Поток отправляет сообщение (переделал пример broadcastsender):

C++ (Qt)
class Thread : public QThread
{
    Q_OBJECT
 
public:
    Thread();
 
protected:
    void run();
 
private slots:
    void broadcastDatagram();
 
private:
    QUdpSocket *udpSocket;
    int messageNo;
};
 

C++ (Qt)
Thread::Thread()
    : QThread( 0 ), messageNo( 1 )
{
    moveToThread( this );
}
 
void Thread::run()
{
    udpSocket = new QUdpSocket;
 
    QTimer timer;
    connect( &timer, SIGNAL( timeout() ), SLOT( broadcastDatagram() ) );
    timer.start( 1000 );
 
    exec();
}
 
void Thread::broadcastDatagram()
{
    QByteArray datagram = "Broadcast message " + QByteArray::number( messageNo );
    udpSocket->writeDatagram(datagram.data(), datagram.size(),
                             QHostAddress::LocalHost, 45454);
    ++messageNo;
}
 

Думаю, проблема в том, что я не использовал метод moveToThread, спасибо.

блин.. вот этот кусок меня радует ... отымей себя сам, простите за аналогии?
помещаем себя, в поток, который собою-же и олицетворяем)

разве не содержимое run() собственно будет выполняться в отдельном потоке? вне зависимости где создан родитель?

не, у меня аналогичное написано в конструкторе (вернее не совсем так: moveToThread( _parent->thread() ); - не помню зачем я это делал - видимо для того, что бы не ругалось на то, что родителя нельзя назначить из другого потока...

но не могли бы вы объяснить подробнее работу данного куска кода? зачем так? в ассистанте и примерах от троллей не нашел чего-то подобного....  ::)
заранее спасибо.

Ну дык, смотрим.  :)
Сейчас этой строки нет.  :)

C++ (Qt)
int main(...)
{
	// Контекст первого потока
	Thread *thread = new Thread;		// Конструируем объект thread, он пренадлежит контексту первого потока.
}
 

C++ (Qt)
void Thread::run()
{
	// Появился контекст второго потока.
 
	QTimer timer;		// Объект timer принадлежит контексту второго потока.
 
	// При соединении сигнала от объекта timer, который принадлежит второму потоку, со слотом объекта thread, который принадлежит первому потоку,
	// будет выбран метод передачи сигналов через очередь событий, т.е. когда в потоке сработает таймер сообщение об этом будет помещено в очередь событий
	// первого потока, соответсвенно слот будет отрабатывать из очереди первого потока.
	// Нам это не нужно! Поэтому мы сообщаем Qt, что мы хотим считать объект thread принадлежащим контексту второго потока.
	connect( &timer, SIGNAL( timeout() ), SLOT( broadcastDatagram() ) );
}
 

Гы) т.е. все просто потому, что метод занимающийся работой с сетью - есть часть наследника QThread?
ну ок))) просто я "думаю немного по другому" - для меня сделать так - это сешать 2 разнородные сущности. - управление потоком и работа с сетью.
 У меня в программе был бы отдельный класс в котором собрано все сетевое взаимодействие и который полностью висел-бы внутри потока и собственно такого аспекта просто бы не возникало..

ок. В любом случае спасибо за пояснения в работе QThread.

Точно, поэтому я думаю moveToThread( this ) и не добавили по умолчанию в конструктор QThread.

http://labs.trolltech.com/blogs/2010/06/17/youre-doing-it-wrong/ (http://labs.trolltech.com/blogs/2010/06/17/youre-doing-it-wrong/)
http://blog.exys.org/entries/2010/QThread_affinity.html (http://blog.exys.org/entries/2010/QThread_affinity.html)
...