Как на создавать потоков по количеству ядер, а потом завершить их? Опции

[RazrFalcon]

Циклично создаются потоки:

for (int i = 0; i < list.count(); ++i) {
    MyThread *myTh = new MyThread();
    QThread *th = new QThread(this);
    connect(cleanerM,SIGNAL(done()),this,SLOT(cleaningFinished()));
    myTh->moveToThread(th);
    th->start();
}

Затем на cleaningFinished я вызываю:

QThread *th = qobject_cast<QThread *>(sender());
th->quit();

Это нормальное решение или есть более правильное?


И как можно завершить все потоки? ака кнопка "стоп".

Сообщение отредактировал RazrFalcon - 5.11.2011, 16:39

[RazrFalcon]

Пока что остановился на таком варианте:

for (int i = 0; i < list.count(); ++i) {
    MyThread *myTh = new MyThread();
    QThread *th = new QThread(this);
    connect(myTh,SIGNAL(done()),th,SLOT(quit()));
    connect(th,SIGNAL(finished()),this,SLOT(workFinished()));
    myTh->moveToThread(th);
    th->start();
}

и

void MainWindow::workFinished()
{
    QThread *th = qobject_cast<QThread *>(sender());
    if (th)
        delete th;

    QList<QThread *> list = findChildren<QThread *>();
    if (list.isEmpty())
        qDebug()<<"all thread finished";
}

Нормальное решение? Вроде пашет.

[PAFOS]

    QThread *th = qobject_cast<QThread *>(sender());
    if (th)
        delete th;

не следует удалять сигнальщика в слоте. для этого есть deleteLater()

[RazrFalcon]

не следует удалять сигнальщика в слоте. для этого есть deleteLater()

deleteLater() - удаляет слишком поздно =/
У меня с ним список ниже не пустой. А должен быть пустой!

[PAFOS]

ну а иначе рискуешь получить Segfauilt в неожиданном месте.

Создай отдельный список и храни там указатели на потоки
в слоте workFinished()

QThread *th = (QThread*)sender();
th->deleteLater();
listOfThreads.removeOne(th);

if( listOfThreads.isEmpty() )
   qDebug() << "all thread finished";

th->deleteLater(); - после этого указатель на QThread уже можно терять.

[RazrFalcon]

Сегфолтов пока не наблюдал.
Плодить кучу переменых/списков нет желания. Люблю там где нужно получать переменные.

[RazrFalcon]

нашел еще один способ:

delete(th);

Не знаю в чем разница между

delete th;

но результат то же.

[Гость_Гость_*]

RazrFalcon, cскажите как узнаёте сколько ядер в системе?
Спасибо.

[RazrFalcon]

RazrFalcon, cскажите как узнаёте сколько ядер в системе?
Спасибо.

QThread::idealThreadCount()

[Влад]

Хм, ну, как оно там точно организовано в ядре Линуксов, это я не знаю, но в Виндоус есть еще такая тонкость: мало насоздавать потоков (процессов) по числу ядер, надо еще не забыть привязать каждый поток/процесс к конкретному ядру. Там для этого предусмотрены специальные функции типа SetThreadAffinityMask() или что-то подобное (лезть в MSDN и уточнять сейчас лень). В противном случае, планировщик все равно имеет возможность по своему усмотрению перекидывать потоки с ядра на ядро, со всеми сопутствующими накладными расходами, - а оно тебе надо?