Потоки, сигналы, слоты и потенциальные касяки если связать все это?

[kuzulis]

Потоки, сигналы, слоты и потенциальные касяки связанные с этим?

Допустим ,например, в моем приложении имеется две "подсистемы" А и B.
Эти подсистемы представляют собой два экземпляра классов, наследуемых от QThread.
1. Поток А в бесконечном цикле передает потоку В сигнал sgReadData(int i)
о том что он хочет прочитать некие данные.
2.Поток В принял этот сигнал, выполнил свой слот и выдал потоку А сигнал о том,
  что данные готовы...
3. поток А принял от потока В сигнал о том что данные готовы и обновил у себя их

(про защиту данных QList от потокобезопасности я опускаю речь ., сейчас не это главное узнать! )

//---------- подсистема А

Код:

class A: public QThread
{
signals:
   void sgReadData(int i)
protected:
   void run();
private slots:
   void slUpdateData(int i, int data);

private:
   QList<int> list;
}
//
void A::run()
{
   while (1) 
   {
     //перебираем все записи в QList и емиттим сигналы о том что классу А нужно получить новые данные
     for (int j=0;j<list.size();++j) {
        emit sgReadData(j);
     }
   } 
}
//обновляем данные
void A::slUpdateData(int i, int data);
{
   list[i] = data;
}

//---------- подсистема B

Код:

class B: public QThread
{
signals:
   void sgDataReady(int i, int data);
protected:
   void run();
private slots:
   void slReadData(int i);

private:
   List<int> list;
}
//
void B::run()
{
 ///  НАДО ЛИ ЧТО ЗДЕСЬ ПИСАТЬ??? 
}
//
void B::slReadData(int i)
{
   emit sgDataReady(int i, list.at(i));
}

в приложении делаем так:

Код:

A *threadA = new(A);
B *threadB = new(B);

connect(A, SIGNAL(sgReadData(int)), B, SLOT(slReadData(int)));
connect(B, SIGNAL(sgDataReady(int,int)), A, SLOT(slUpdateData(int,int)));

threadA->start();
threadB->start();

Вопрос:
1. корректно ли так реализовывать мою идею? (т.е не "захлебнутся" ли потоки (приложение)  таким количеством данных)
2. Какие "косяки" могут вылезти?
3. что если в сигнале класса В sgDataReady, указать для данных не тип int а указатель на *int ? (хотя везде в
    ассистенте передают типы а не указатели!)

[Rcus]

Assistant -> Thread Support in Qt же.
1. Работать не будет, читайте ман (нужна петля обработки событий)
2. не обрабатывается команда завершения потока, возможно нарушение приоритетов (starvation)
3. А зачем?

[ритт]

> про защиту данных QList от потокобезопасности
каково, а? )

> A *threadA = new(A);
> B *threadB = new(B);
> connect(A, SIGNAL(sgReadData(int)), B, SLOT(slReadData(int)));
тоже неплохо...

в целом идея неверная. мб для отдельно взятого случая подобным образом будет и проще, но бесконечный emit sgReadData(j) - это что-то уже за гранью.

как я понял из кода выше, списки в обоих тредах должны синхронизироваться (из В в А) - не проще ли использовать что-то вроде QSharedMemory?
ну, или хотя бы посмотри QWaitCondition

[pastor]

2 kuzulis: Возми книгу Jasmin Blanchette, Mark Summerfield C++ GUI Programming with Qt 4 (существут перевод этой книги на русский) и прочти 14 раздел Multithreading.

[kuzulis]

1. Работать не будет, читайте ман (нужна петля обработки событий)

блина... читаю... ток голова пухнет! и что - то не могу понять!

2. не обрабатывается команда завершения потока, возможно нарушение приоритетов (starvation)

это я опустил дабы не загромождать код

3. А зачем?

ну, чтобы поток В прислал потоку А указатель на данные типа *int , т.к поток А тогда по этому указателю вычитает данные быстрее нежели из переменной ... типа для скорости

> про защиту данных QList от потокобезопасности
каково, а? )

да блина главное смысл понятен о чем я!

тоже неплохо...

что имеете ввиду?

в целом идея неверная. мб для отдельно взятого случая подобным образом будет и проще, но бесконечный emit sgReadData(j) - это что-то уже за гранью.

ну мне нужно из подсистемы В в подсистему А бесконечно слать некие данные... в принципе я мог бы в бесконечном цикле потока А вызывать некую ф-ю типа B::readData(int i, int data) , предварительно объявив и реализовав ее в подсистеме В... но при этом придется включать #include "В.h" ...
И вообще, в ассистенте написано, что сигналы и слоты для того еще введены, чтобы можно было стыковать объекты м/у собой, которые ничего не знают друг  о друге (вот я и стыканул)

как я понял из кода выше, списки в обоих тредах должны синхронизироваться (из В в А) - не проще ли использовать что-то вроде QSharedMemory?
ну, или хотя бы посмотри QWaitCondition

нет, вы наверное неправильно поняли.... это я просто списки сюда всунул ... а реально дело так должно быть (в моем идеале )
1. поток А шлет потоку В сигнал о том, что он хочет из внутреннего хранилища (которое находится в подсистеме В) из "ячейки" с идентификатором ID = 333 получить данные (реально данные могут быть любыми, но в примере это int) : sgReadData(333);
2. поток В принимает этот сигнал и у себя запускает слот slReadData(333);
3. в этом слоте происходит "декодирование" числа 333 (например им закодирован некий путь к объекту внутри подсистемы В в котором хранятся данные)
4. после раскодирования - в слоте происходит чтение этих данных из этого объекта и пусть прочитали число = 999;
5. после того как прочитали - в слоте класса В выдаем сигнал для подсистемы А типа по ссылке ID=333 прочитали данные 999 : sgDataReady(333,999)
6. подсистема А приняв этот сигнал, запускает слот slUpdateData(333, 999) и записывает эти данные 999 в свое внутреннее некое хранилище данных , у которого свои идентификаторы

т.е листы - это просто типа массивов каких-то данных (в принципе я массивы мог бы всунуть)

вот как мне нужно сделать!!!
типа приложение состоять должно из нескольких подсистем А, В, С .. и т.п ..  которые должны работать в своих потоках и общаться между собой (передавать/принимать данные)  желательно только с помошью сигналов и слотов, раз уж придумали тролли этот механизм!

фухх..

[kuzulis]

2 kuzulis: Возми книгу Jasmin Blanchette, Mark Summerfield C++ GUI Programming with Qt 4 (существут перевод этой книги на русский) и прочти 14 раздел Multithreading.

там нет того что мне нужно! там все не то!

[ритт]

1. Работать не будет, читайте ман (нужна петля обработки событий)

блина... читаю... ток голова пухнет! и что - то не могу понять!

от чего там пухнуть? хочешь, чтобы в потоке вызывался сигнал - используй ивентлуп (exec() потоку либо собственный). а вечный цикл убрать. /* кстати, "while (1)" называется "forever" */

[kuzulis]

от чего там пухнуть? хочешь, чтобы в потоке вызывался сигнал - используй ивентлуп (exec() потоку либо собственный). а вечный цикл убрать. /* кстати, "while (1)" называется "forever" Улыбающийся */

Я не понял насчет евентлупа! Я запуталсо!

[ритт]

тогда задай себе вопрос: "а нужны ли вообще мне эти потоки?"
если ответ себе будет "да, нужны - без них никак", брось всё на время - отдохни, а затем начинай читать про потоки с самого начала...
без понимания примитивов работы с потоками, того и гляди, получится приложение, "защищённое от потокобезопасности"
в качестве альтернативы посмотри на QtConcurrent

[kuzulis]

да! нужны!

я с exec() не очень понял, т.к примеров нету!

т.е если я в вместо A->start() напишу А->exec() - то запустится цикл обработки сообщений и следовательно можно не переопределять ф-ю run() ?

[ритт]

а ничего, что QThread::exec() защищённый (protected)?

[kuzulis]

О_о.. башка не варит под конец дня...

Значит надо делать так?

Код:

void B::run
{ exec(); }

а в main.c писать: B->start() ?
так что-ли ?

[Dendy]

Именно. А завершить выолнение exec() с помощью вызова thread->quit() или thread->exit( myReturnCode ).

[ритт]

Именно. А завершить выолнение exec() с помощью вызова thread->quit() или thread->exit( myReturnCode ).

а ещё можно сделать так:

Код

C
B::~B()
{
  quit();
  wait();
}
 

и безопасно удалять через delete thread;

либо

Код

B::B(...)
{
  connect(this, SIGNAL(finished()), this, SLOT(deleteLater()));
}
 

и удалять через thread->stop();

[Dendy]

2 Константин, вот шустрый, я уже почти написал как нужно правильно.