QThead. Как? Опции

[smartchecker]

Нужно реализовать подобную схему взаимодействия thread'ов с отображением процесса.
Объясните как?

Эскизы прикрепленных изображений

 

[Алексей1153]

мне кажется, тут надо начать издалека.

1) Для каждой задачи создавать список пройденных условных узлов, к ним же приписывать время прохождения. Этот список передаётся между потоками вместе с задачей.

2) в конце все списки нужно объединить в один граф, использую имена условных узлов, к рёбрам прикрепить время выполнения

3) нарисовать граф

[smartchecker]

Мне бы хоть пример какой-нибудь.

[smartchecker]

мне кажется, тут надо начать издалека.

1) Для каждой задачи создавать список пройденных условных узлов, к ним же приписывать время прохождения. Этот список передаётся между потоками вместе с задачей.

2) в конце все списки нужно объединить в один граф, использую имена условных узлов, к рёбрам прикрепить время выполнения

3) нарисовать граф

Тут приоритеты и время прохождения сущности весьма условные.
Важно только то, что какие-то потоки запускают другие.
На картинке поток D запускает потоки E,F,G. Последний из завершившихся потоков запускает поток H.

[PAFOS]

На картинке поток D запускает потоки E,F,G. Последний из завершившихся потоков запускает поток H.

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

[smartchecker]

На картинке поток D запускает потоки E,F,G. Последний из завершившихся потоков запускает поток H.

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

У меня в голове всё равно не складывается как пнуть один поток, при условии что он должен дождаться завершения двух-трёх других.

[PAFOS]

void ThreadManager::run()
{
    QThread *thr = 0;

    // Стартуем потоки А и B
   
    thr = new ThreadA();
    connect(thr,SIGNAL(finished()),this,SLOT(threadFinished()));
    //connect(thr,SIGNAL(terminated()),this,SLOT(threadTerminated())); <- при необходимости
    thr->start();

    m_threads << thr; // QList<QThread*> m_threads - приватный член ThreadManager

    thr = new ThreadB();
    connect(thr,SIGNAL(finished()),this,SLOT(threadFinished()));
    //connect(thr,SIGNAL(terminated()),this,SLOT(threadTerminated())); <- при необходимости
    thr->start();

    m_threads << thr;

   // Необходимо, чтобы получать сигналы и события от запущенных потоков
   exec();
}


void ThreadManager::threadFinished()
{
    QThread *thr = dynamic_cast<QThread*>(sender());
    if( thr == 0 )
    {
       /// WTF???
       return;
    }
    m_threads.removeOne(thr);
    thr->deleteLater();
  

    // смотрим какой конкретно поток завершился, чтобы взять у него результат работы
    if( dynamic_cast<ThreadA*>(thr) )
    {
       m_result.setResultFromA(  ((ThreadA*)thr)->result() );
    }
    else if( dynamic_cast<ThreadB*>(thr) )
    {
       m_result.setResultFromB(  ((ThreadB*)thr)->result() );
    }
    else
    {
       //....
    }
    


    if( m_thread.isEmpty() )
    {
       // Завершился последний поток.
       // результаты работы потоков в переменной m_result 
       // можно запускать третий поток

        m_threadD = new ThreadD(); // ThreadD *m_threadD -  приватный член ThreadManager
        m_threadD->setResult( m_result );
        ///connect(...)
        ///...
        m_threadD->start();
    }
}

Сообщение отредактировал PAFOS - 22.11.2011, 16:42

[smartchecker]

m_result - какого типа?

[PAFOS]

m_result - какого типа?

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