0

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

Вот пример, есть класс identificator, .h:

class identificator:public QObject {
    Q_OBJECT
public:
    identificator();
    virtual ~identificator();
private:
    int id;
private slots:
    void printID();
public:
    void setID(int i);
    int getID();
signals:
    void finished();
};

.cpp:

#include "identificator.h"
#include <stdio.h>

identificator::identificator() {
    id=0;
}

identificator::~identificator() {
    // TODO Auto-generated destructor stub
}

void identificator::setID(int i)
{
    id=i;
}

int identificator::getID()
{
    return id;
}

void identificator::printID()
{
    for(;;)
    {
        printf("%d\n",this->getID());
    }
    emit finished();
}

а вот main.cpp:

#include <QtCore>
#include <QCoreApplication>
#include <QApplication>
#include "myThread.h"
#include "identificator.h"
#include <stdio.h>

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);
    printf("Hello\n");
    identificator *first=new identificator();
    identificator *second=new identificator();
    QThread *thread1=new QThread;
    QThread *thread2=new QThread;
    first->setID(3);
    second->setID(4);
    QObject::connect(thread1, SIGNAL(started()), first, SLOT(printID()));
    QObject::connect(thread2, SIGNAL(started()), second, SLOT(printID()));
    QObject::connect(first, SIGNAL(finished()), thread1, SLOT(quit()));
    QObject::connect(second, SIGNAL(finished()), thread2, SLOT(quit()));
    thread1->start();
    thread2->start();
    return a.exec();
}

Ожидаю, что в консоль будет выводится числа 3 и 4, вразнобой,бесконечно долго, но при запуске в консоль выводится только 3. Очень прошу, объясните мне пожалуйста, как добиться их параллельной работы? Заранее спасибо!


Вычитал, что алгоритм должен быть примерно такой:

  1. Создание потока.
  2. Создание объекта и перенос в поток.
  3. Установка сигнально слотовых связей.
  4. Запуск потока с заданным приориетом.

Поэтому добавил, как посоветовали: moveToThread()

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);
    printf("Hello\n");
    identificator *first=new identificator();
    identificator *second=new identificator();
    QThread *thread1=new QThread;
    QThread *thread2=new QThread;
    first->setID(3);
    second->setID(4);
    first->moveToThread(thread1);
    second->moveToThread(thread2);
    QObject::connect(thread1, SIGNAL(started()), first, SLOT(printID()));
    QObject::connect(thread2, SIGNAL(started()), second, SLOT(printID()));
    QObject::connect(first, SIGNAL(finished()), thread1, SLOT(quit()));
    QObject::connect(second, SIGNAL(finished()), thread2, SLOT(quit()));
    thread1->start();
    thread2->start();
    return a.exec();
}

Добавил moveToThread() и после инициализации и после connect() оба варианта не помогли....

Буду благодарен за помощь.

11
  • А где вы привязываете свой identificator к QThread? 27 июл 2016 в 10:47
  • в main.cpp, через функцию connect(), или нужно внутри класса делать привязку к потоку? 27 июл 2016 в 10:53
  • А, точно, не увидел... 27 июл 2016 в 10:57
  • 1
    @infernalcucumber main.cpp idprinter.h 27 июл 2016 в 17:38
  • 1
    @infernalcucumber, у меня чередуются 3 и 4. Хотя надо сказать дома и на работе это выглядит по-разному. Дома – 33434434343343, на работе – 3333333444444433333 28 июл 2016 в 6:00

1 ответ 1

1

После коннектов попробуйте добавить

first->moveToThread(thread1);
second->moveToThread(thread2);

Однако я рекомендую посмотреть в сторону QtConcurrent::run(). Это штука более высокого уровня, может с ней будет малость проще на первых порах. Так же есть QRunnable + QThreadPool, которые для некоторых задач могут быть удобнее чем QThread.

Как используется Qthread лучше всего посмотреть в справке, там очень доступно все описано. Если в двух словах, то нужно создать класс, слот которого будет выполнятся в отдельном потоке(в документации его назвали Worker). Потом объект этого класса помещается в поток(worker->moveToThread(&workerThread);). И когда какой-нибудь сигнал активирует слот нашего worker-а, то этот слот выполнится в отдельном потоке.

6
  • Добавил moveToThread(), не помогло... Попробовал вариант с QtConcurrent::run() - тоже, блокируются все потоки после запуска первого... 28 июл 2016 в 5:30
  • @infernalcucumber, а если создать QThreadPool и вызвать maxThreadCount, что получится? 28 июл 2016 в 6:03
  • QThreadPool тоже почему то аналогично работает - выполняется сперва функция первого потока, потом второго, т.е. последовательно 28 июл 2016 в 12:27
  • @infernalcucumber, maxThreadCount что возвращает? 28 июл 2016 в 12:40
  • ссылка - попробовал оттуда вызвать maxThreadCount() перед start. В консоль выводится : "1". 29 июл 2016 в 4:23

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.