Всем привет

Столкнулся с проблемой... В примере Threaded Fortune Server не описан процесс обмена данными... они только посылаются и сразу же закрывается поток (что очень странно, смысла в многопоточности для такой проги ноль...)

Я пытался переделать и совместить Threaded Fortune Server c Loopback... И уже разобрался что в потоке нужно запустить event loop через exec() но натолкнулся на проблему.

Как я понял если для QTcpSocket указать socketDescriptor то он начинает отрабатывать сообщения этого сокета... Так вот если я в потоке пытаюсь поставить setSocketDescriptor(socketDescriptor) то ругается в окно вывода проги:

А если переношу QTcpSocket в новосозданный поток (thread->tcpServerConnection.moveToThread(thread)), причем ругается в exec():


В общем не понимаю я всей этой архитектуры... А Qt написали такие скудные примеры =\
Помогите кто чем сможет... На данный момент это простенький чат пишется для тестирования...

UPD:
Processing Qt 4.5 moveToThread() или метод “Мюнхгаузена”

Это сообщение отредактировал(а) SwordOfDeath - 19.7.2009, 11:37

попробую догадаться, но не совсем понял, где что создается
1) tcpServerConnection - это объект переменная член класса? создается где? в функции run() или нет?
2) если tcpServerConnection создается в функции run, то ты НЕ можешь делать вот так из основного потока

Так как за объект класса QTcpSocket отвечает дочерний поток, ты должен ему передавать дескриптор сокета, средствами сигналов - слотов или посылая сообщения фунцией postEvent (sendEvent), где можешь передавать сам файловый дескриптор
3) По поводу этого я не уверен, 

а именно, где ты создаешь объект сокета... могу лишь предположить, что ты назначаешь родителя объекту tcpServerConnection, что делать, при использовании moveToThread НЕЛЬЗЯ
4) Хорошо бы привезти код, не весь, а только концептульный твоей проблеме, было бы нагляднее


Это сообщение отредактировал(а) null56 - 19.7.2009, 23:04

Я бы не рекомендовал использовать не свои классы с методом moveToThread. Этот метод за раз переносит только один объект, если при этом объект создает внутри себя или пытается использовать другие QObject'ы, то без их переноса возникнет проблема.

Таксь последовал вашим замечаниям по поводу moveToThread, и теперь создаю tcpServerConnection в run()... Таким образом мне уже не нужно его куда либо переносить.

Покопавшись разобрался почему ругается в exec() созданного потока;
Я связываю сигнал из потока с слотом из главного потока:


В мануале написано что Сигнал-Слот без проблем работает между потоками... А тут вот грабли...
Или может это грабли с передаваемыми данными? Как правильно это делать?

Проверь не пишется ли в консоль что-то связанное с QByteArray и qRegisterMetatype.

Вот полный вывод начиная от старта и заканчивая закрытием:



Это сообщение отредактировал(а) SwordOfDeath - 20.7.2009, 12:12

я имел в виду исходный код твоей программы

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

Привожу частичный код



Как видно он ничем не отличается от примеров Qt... кроме как запуском eventloop'a и связыванием сигнал-слота в разных потоках.


UPD:
Двигаюсь дальше... Ошибку вызывает не сам Сигнал-Слот и не его параметры... А код который описан в слоте... Так как будто этот код вызывается прямо в контексте потока который сгенерил сигнал... Указание Qt::QueuedConnection результата не дали...


Это сообщение отредактировал(а) SwordOfDeath - 20.7.2009, 19:33

Я набил пример тебе маленький, где использую ТВОЙ код...
Сервер висит в ожидании, при поступлении нового подключения создает объект нити, передавая туда дескриптор.
Клиент, коннектится к серверу, как только подлючается в слоте onConnected посылает строку серверу... 
Все работает без проблем...
цепляй прикрепленный файл, там отдельно собирешь клиента и сервера, запустишь и посмотришь, правильно  ли я понял твою идею и твой вопрос

Присоединённый файл ( Кол-во скачиваний: 37 )
 chat.tar.bz2 1,63 Kb

ЗЫ: естетсвенно, чтобы не было

ты сам должен позаботиться о том, чтобы завершить eventloop и дочерний поток, перед тем, как завершится основной поток

Присоединённый файл ( Кол-во скачиваний: 42 )
 chat.tar.bz2 1,63 Kb

Спасибо огромное за помощь... Но кажется это не решит моей проблемы...
Так как вы в parseMessage(int value, QByteArray msg) вызываете qDebug() которому не важно в каком потоке он вызван...
Мне же в этой функции нужно работать с данными и вызывать функции главного потока...

Я не понимаю, приведи пример, того, чего ты хочешь

слот будет обрабатываться в основном потоке, так как он создан вместе с оъектом ChatHostServer в основном потоке

Добавлено через 3 минуты и 53 секунды

приведи пример кода в слоте

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

Вот он то и создает ошибку... Чувствую себя паршиво что не отдебажил все как положено до самого конца =\

Также эту же ошибку вызывает добавление tcpServerConnection->write(tcpServerConnection->readAll()); в слот void ChatHostThread::incomingData()

Проверил на вашем примере... Та же ошибка при попыке отправки сообщения с сервера клиенту...

Это сообщение отредактировал(а) SwordOfDeath - 20.7.2009, 21:34

НИИИИИИИЗЗЯЯЯЯЯЯЯЯЯЯЯЯЯЯЯ, написал же чуть выше про подобное...
Объект класса QTcpSocket обслуживается дочерней нитью и лезть к этому объекту из другой нити, нИИИИИИИИзЯ...
Можно передать эти данные дочерней ните, которая уже будет отсылать их твоему объекту сокету...
примерно так дополню твой класс ChatHostThread


Функция run()


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


Переменную член класса так же делаешь своим TcpSocket и в функции run создаешь его же...


Теперь через такую Ж мы получили следующее:
вызов функции sendMessage(QByteArray message) (даже если это слот) сгенерит сигнал, слот которого обработается в дочернем потоке объекта нашего класса TcpSocket
во... )

Это сообщение отредактировал(а) null56 - 20.7.2009, 21:45

Так я так и делаю!...
Не лезу я к этому объекту из другой нити... Я все через Сигнал-Слоты гоняю...
И опять же проблему можно повторить и в вашем примере:
Добавив в ChatHostThread :: incomingData()

Хм.. но данные отправляются...