QTcpSocket в QThread

man moveToThread()

Код в студию же. Лечить по фото не умеем.

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

Для многопоточных приложений используй SObjectizer. Отличная библиотека для цпп! И это не шутки!

man moveToThread()

А можно поподробнее, что это даст? QTcpSocket создаю и использую конечно же в отдельном потоке.

В инете советуют вызвать exec на текущем QThread

o_0

С moveToThread() разобрался. Но теперь я не понимаю, что мне с этим делать. exec() вызывать нужно, чтобы включилась очередь событий потока, без этого не представляю как осуществлять коммуникацию между потоками. Но exec() блокирующая и мне уже негде осуществлять мой бесконечный цикл, а мне это необходимо. Вот понаделали, не пойми как использовать. Мне нужен exec(), но не блокирующий.

http://habrahabr.ru/post/150274/

Это я уже успел прочесть :) Эх чую придется мне свою очередь городить, на ненавистных синхро примитивах. Но в qt написано, что без событий QTcpSocket нормально не работает. Правда не понятно, нахрена ему события потока в котором он был создан.

Большая часть путаницы происходит из-за того, что QThread используется как абстракатный класс. Такуим образом, единсветнный путь использования Qthread - это создание его подкласса и переопределение метода run(). И это действительно было так, до версии Qt 4.4, начиная с которой метод QThread::run() получил реализацию по умолчанию, следовательно необходимость в создание потомков класса QThread отпала. Главной причиной этому послужил тот факт, что создание потомков класса QThread может препятствовать использованию слотов подклассом.

exec не нужен

Зачем цитируешь? Сказал же что прочел эту статью и понял, но что делать в моем случае все равно не понимаю.

What? Без exec очередь событий не работает. Сигналы сразу идут лесом.

написано же - с 4.4 работает. А ваще уже написали - минимальный нерабочий пример в студию

Что? Мы о разных вещах говорим. События не работают и в 5.5 без exec(). Пример не нужен. Мне нужно выполнять бесконечную операцию в цикле, в отдельном потоке и при этом очередь сигналов тоже нужна. exec() блокирующий и не позволяет мне гонять бесконечный цикл. И если я правильно понимаю QTcpSocket какого-то рожна тоже нужна очередь в потоке в котором он был создан, но тут не уверен.

class TcpParser : public QObject
{
    Q_OBJECT
public:
    TcpParser()
    {
        moveToThread(&t);
        t.start();
        QMetaObject::invokeMethod(this,"init_inthread",Qt::BlockingQueuedConnection);
    }
    ~TcpParser()
    {
        QMetaObject::invokeMethod(this,"close_inthread",Qt::BlockingQueuedConnection);
        t.quit();
        t.wait();
    }
private slots:
    void readTcp()
    {
        while(tcp->bytesAvailable() > 0)
        {
            rxBuff.append(tcp->readAll());
        }
        parseTcp();
    }
    void parseTcp()
    {
        if(rxBuff.size() < MESS_MIN_SIZE) return;
        ...
        emit...
        rxBuff.remove(0,...);
        QMetaObject::invokeMethod(this,"parseTcp",Qt::QueuedConnection);
    }
private:
    QThread t;
    Q_INVOKABLE void init_inthread()
    {
        tcp = new QTcpSocket();
        tcp->connectToHost(...);
        connect(tcp,&QTcpSocket::readyRead,this,&TcpParser::readTcp,Qt::QueuedConnection);
    }
    Q_INVOKABLE void close_inthread()
    {
        delete tcp;
    }
    QTcpSocket* tcp;
    QByteArray rxBuff;
}

например

Да чего за exec() то?? Этот http://linux.die.net/man/3/exec что ли? Или QApplication::exec()?

И где же здесь бесконечный цикл? Без него я прекрасно понимаю как сделать. Должен быть бесконечный цикл, который периодически может отвлекаться на постороннее, но основную массу времен должен крутиться именно он. Неужели я так плохо объясняю?

QThread.exec(). У QApplication есть processEvents, у QThread я аналога не могу найти.

exec не нужен

Ну получи диспетчера событий через QThread::eventDispatcher(), а потом вызывай в своём цикле его processEvents() не?

http://doc.qt.io/qt-5/qthread.html#eventDispatcher

Ну и в принципе анонимус правильно говорит - в exec нет необходимости.

Да етить, бесконечный это while(true) который никогда не выходит.

Спасибо, буду разбираться.

вид сбоку

exec так или иначе присутствует всегда, вся только разница что его теперь не надо пихать самому.

Ещё можно QCoreApplication::processEvents() из цикла соответствующего потока вызывать - тогда эта функция будет обрабатывать события для этого потока.

ТС хочет поковырять в носу через жопу и ему тут же предложили нож, шило и пистолет.

А еще есть QEventLoop...

Вот и не пихай, сделай как в примере. run() переопределять не нужно. От QThread наследоваться тоже.

Вообще с этим event loop это паттерн Actor, а ОП зачем-то в его event loop хочет ещё какую-то свою обработку делать. Плохо паттерны мешать. Либо одно не будет хорошо работать, либо второе.

Огромное спасибо. Thread::eventDispatcher()::processEvents работает великолепно. QTcpSocket стал работать как и положено. Это все что мне было нужно.

Это я уже успел прочесть :) Эх чую придется мне свою очередь городить, на ненавистных синхро примитивах.

Ты прочитал но не понял - так точнее ;) moveToThread дает почти идеальный способ работы в потоках без явного задействования синхро-примитивов... Что может быть вкуснее? Но помни что с объектом, над которым сделали moveToThread можно безопасно работать лишь через сигналы-слоты, а если надо напрямую дернуть слот то используй QMetaObject::invokeMethod + QueuedConnection...

Паттерны это всего лишь паттерны, задачи бывают разные.

Поэтому, луше ТС отговорить делать не правильно, а не предлагать ему сомнительные методы, пусть они и решат его проблему. ;)

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

Я же написал, что мне был нужно. :) «Стандартный» подход у меня не канает. У меня цикл крутиться всю жизнь приложения и события мне тоже нужны. События здесь играют роль вспомогательную.

+1, может человек медицинскую технику делает, пациентами можем стать мы сами... =))) Так что да, только правильные методы! :)

И это можно реализовать с exec, о чем уже все пишут-пишут.

Балин, как? Я могу отправить бесконечный цикл в очередь событий, но как я получу другие события? Это событие заблокирует все остальные.

Нужно представить бесконечный цикл по другому. Посмотри внимательно на пример анонимуса и отвлекись от «мне обязательно нужен while( true )».

Цикл обработки событиц и есть твой бесконечный цикл, он уже есть. Попробуй в него встроиться.

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

dispatcher->processEvents как раз и позволяет встроиться.

Это не встраивание в цикл Qt, а ноборот - обработка событий из твоего цикла.

Вы просто зациклились на enterprise приложениях. В играх/симуляторах к примеру данный подход применяется повсеместно. Там бесконечный цикл является главнейшим объектом.

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

Из какого моего цикла? Можно пример?

Вот об этом мы тебе и говорим. Бесконечный цикл и спрятан в exec - он есть из коробки. А ты пытаешся добавить еще свой.

Таймер это онанизм, бесконечный цикл это рабочая лошадка, простой здесь недопустим. Самому класть, это через пользовательский ввод что-ли? Не подходит, пользователя вообще может не быть.

И что мне этот цикл дает, если они ничего полезного мне не делает, а только диспатчит события.