Передача сокета в другой поток

[qtkoder777]

Здравствуйте.
Возникла задача написать такой сервер:
Сервер должен получить данные от клиентов, провести над ними некоторые вычисления и вернуть результат клиенту.
В процессе вычислений могут поступать новые запросы.

Пытаюсь сделать так:
Ввёл структуру, в которой запоминаю сокет клиента, которому надо отослать результат работы с data_.

Код

C++ (Qt)
struct ThreadData
{
      Data data_;
      QTcpSocket* socket_;
};

и очередь QQueue этих структур, которая заполняется в основном потоке

Вычисления крутятся в отдельном потоке наследнике QThread.
Данные извлекаются из очереди, обрабатываются, и отправляются клиенту с помощью

Код

C++ (Qt)
socket_->write()

, если очередь пуста, крутится бесконечный цикл.

Фактически, из потока вычислений данные НЕ ДОХОДЯТ до клиента, хотя write завершается без ошибки.
В основном потоке данные по тому же сокету отправляются и доходят.

Читал где то на другом форуме, что сокеты нельзя передавать между потоками.
Так ли это? И как надо поступать?

[Old]

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

[qtkoder777]

Откуда сокет вообще знает в какой он нитке - это особенность Qt?
Подходит ли вообще Qt для написания таких программ?
Может стоит смотреть в сторону других библиотек, раз в Qt такие сложности.

[Old]

Откуда сокет вообще знает в какой он нитке - это особенность Qt?

Для того, что бы обеспечить правильную работу сигналов в многопоточных программах, в Qt введено понятие контекст потока.
Изменяется он с помощью метода: QObject::moveToThread.

Подходит ли вообще Qt для написания таких программ?
Может стоит смотреть в сторону других библиотек, раз в Qt такие сложности.

Скажем так, такие программы на Qt можно писать. Насколько это будет эффективно вопрос другой.
Я лично использую для этого boost::asio.

[qtkoder777]

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

А как вернуть результат в нить сетевого обмена?

[Old]

А как вернуть результат в нить сетевого обмена?

Например, можно возвращать готовый для отбравки объект QByteArray.

[qtkoder777]

А как вернуть результат в нить сетевого обмена?

Например, можно возвращать готовый для отбравки объект QByteArray.

Как сообщить что данные готовы к отправке? Сигнал-слот?

[Old]

Сигнал-слот?

Как вариант.

[sergek]

Сигнал-слот?

Как вариант.

А это не единственно правильный вариант?

[Old]

А это не единственно правильный вариант?

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

[qtkoder777]

Как следует поступать когда потоку "нечего делать"?
Крутиться в бесконечном цикле и проверять, не появилось ли чего в очереди - это правильно или нет?

[Old]

В идеале он должен спать и просыпаться только когда появилась работа. Поищите по форуму, было несколько тем с примерами про очереди и QWaitCondition.

[qtkoder777]

Какие параметры должен иметь сигнал для передачи результатов?
Сигнал получат все потоки соединений, надо как-то узнать какому потоку предназначен сигнал.
То есть два параметра - строка результата и this потока?

[Old]

В самом простом случае с Qt-сигналами: сетевая нитка должна передать рабочей какой-то идентификатор клиента/сокета, от которого получен этот запрос и исходные данные для работы. После завершения обработки рабочая нитка должна передать сетевой тот же идентификатор клиента/сокета и результат работы. Сетевая нитка по идентификатору находит нужный сокет и отправляет в результат.

[qtkoder777]

Какие особенности у межпоточного connect-a?
Обнаружилось, что после такого connect-a сокет, который в нити thread, перестаёт получать данные (ft - нить вычислений)

Код

C++ (Qt)
connect(&ft, SIGNAL(dataReady(const QString &)), thread, SLOT(slotSendData(const QString &)));

Код

C++ (Qt)
void FortuneThread::slotSendData(const QString &s)
{
	tcpSocket_->write(s.toAscii());
}

Есть какой-то загадочный последний необязательный параметр, может там чего надо прописать?