Передачи сигнала в определенный потоков.

[venom2013]

Добрый день. Постановка задачи: есть несколько девайсов (количество переменное), необходимо создать поток для каждого и передавать туда данные на обработку.
Мой алгоритм реализации: при запуске программы создать поток для каждого девайса и назначить ему ид - имя девайса, например "0024". Когда я получаю сигнал от девайса, то смотрю на имя и передаю соответствующий поток.
Проблема в том что я не знаю как назначит ид (имя) потоку. Возможно вопрос глупый но опыта работы с потоками 0.     

[mutineer]

Завести переменную в наследнике QThread. Или использовать QObject::objectName

[venom2013]

Извините, а можно пример? Буду очень благодарен

[mutineer]

Пример чего?
Пример наследования и добавления переменных - в любой книге по С++
Пример objectName в документации

[venom2013]

Большое спасибо. Разбираюсь

[venom2013]

Создаю поток в циклы:

Код:

 while (queryDevice.next()){

        MyThread *thread = new MyThread();
        thread->setObjectName(queryDevice.value(0).toString());
 }

Запрос возвращает n девайсов и каждому потоку назначаю имя соответственно девайсу. Как мне обратиться к потоку с изменим например "0024"?

[mutineer]

сложить потоки в QMap, например. тогда можно и без setObjectName обойтись

[venom2013]

а если сделать так:

Код:

    while (queryDevice.next()){
        
        MyThread *thread = new MyThread();
        threads.append(thread);
        thread->setObjectName(queryDevice.value(0).toString());
        connect(this, SIGNAL(StringSignal(QString , QString)), thread, SLOT(StringSlot(QString , QString)));
    }

......

    if(threads.at(0)=="0024")
        threads.at(0)->start();

это будет правильно?

[mutineer]

нет, потому что MyThread вряд ли можно сравнить со строкой
используй threads.at(0)->objectName()

[venom2013]

Большое спасибо!!!

[venom2013]

Извините но не могли бы Вы подсказать.
Создаю потоки и слоты:

Код:

while (queryDevice.next()){

        MyThread *thread = new MyThread();
        threads.append(thread);
        thread->setObjectName(queryDevice.value(0).toString());
        connect(this, SIGNAL(StringSignal(QStringList)), thread, SLOT(messageFomMtHostTh(QStringList)));
        connect(thread, SIGNAL(StringSignalToMain(QString)), this, SLOT(slotWriteToMtHost(QString)));
        connect(thread, SIGNAL(logMtHost(QString)), this, SLOT(slotLogFromMtHost(QString)));
        connect(thread, SIGNAL(logPostgres(QString)), this, SLOT(slotLogFromPostgres(QString)));
        connect(thread, SIGNAL(logServer(QString)), this, SLOT(slotLogFromServer(QString)));
        connect(thread, SIGNAL(finished()), this, SLOT(slotThFinished()));
    }

Код:

            if(!threads.at(i)->isFinished())
                threads.at(i)->start();
            list.append(threads.at(i)->objectName());
            qDebug()<<threads.at(i)->objectName()<<thread()->currentThread();    //"0024" QThread(0x889c58) 
            threads.at(i)->messageFomMtHostTh(list);

Код:

 virtual void run()
     {
         qDebug()<<currentThreadId()<<currentThread();   //0xf30 MyThread(0x7b62a0, name = "0024") 
         //делаем что то в контексте нового потока
         exec();			//запускаем обработку очереди сообщений потока

     }

Запускается тот поток который мне нужно (функция run возвращает). А когда посылаю сообщения "threads.at(i)->messageFomMtHostTh(list);" в функцию

Код:

        thread()->currentThread()->objectName(); //пустая строка 

 

Где ошибка? Извините возможно вопрос глупый но я уже немного запутался.

[venom2013]

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

Код:

    timer->stop();
    emit  finished();

.....   
 if (thread()->isFinished())
            qDebug()<<thread()->currentThread();

ответ должен быть "MyThread(0x617680, name = "0024") "

[mutineer]

threads.at(i)->messageFomMtHostTh(list);
при таком вызове выполнение происходит не в потоке из списка (который ты проименовал), а в текущем рабочем потоке (подозреваю что основной поток приложение), который не именован, поэтому и пустая строка вместо имени.

Ну это если я правильно понял этот твой сумбурный поток сознания

currentThread() - это статическая функция, она возвращает текущий поток, то есть поток, в котором сейчас происходит выполнение

[venom2013]

да все правильно ты понял  . Как вызвать поток из списка? Я целый день над этим сижу и уже не соображаю.

[mutineer]

Как вызвать поток из списка?

Что значит "вызвать поток"?