Многопоточная обработка массива

[__Heaven__]

Интересно. Кутёвый форич в том ли числе

[__Heaven__]

Ещё интересуют пару моментов.
При использовании распараллеливания операция new или QVector::resize(n) может привести к нахлёсту памяти?
Ещё интересует понятие reentrant - мне его никак не осознать. Означает ли оно, что я могу спокойно запараллелить QVector::append в 4 потока?

[__Heaven__]

Насчёт QVector::append  сам провел тест.

Код

C++ (Qt)
#pragma omp parallel for
    for (int i = 0; i < 100000000; ++i)
    {
        vec.append(i);
    }
 

Сначала получил ошибку в работе с памятью, а когда предварительно зарезервировал место, то получил размер массива 34171332

[Igors]

Ещё интересуют пару моментов.
При использовании распараллеливания операция new или QVector::resize(n) может привести к нахлёсту памяти?
Ещё интересует понятие reentrant - мне его никак не осознать. Означает ли оно, что я могу спокойно запараллелить QVector::append в 4 потока?

Любые не-константные операции с любым контейнером НЕ "потокобезопасны" (NOT thread-safe) и ведут к крашу. Reentrant к этому отношения не имеет, это просто утверждение что ф-ция/метод отработает корректно если будет вызвана из самой себя, непосредственно или через цепочку др вызовов.

Если в параллельных вычислениях формируются результаты требующие сохранения в контейнере, то стандартная техника - каждая нитка пишет в свой контейнер, потом все сливается. Есть и менее хлопотный (но и менее эффективный) способ

Код

C++ (Qt)
#pragma omp parallel for
for (int i = 0; i < 100000000; ++i)
{
#pragma omp critical
     vec.append(i);
}
 

Правда в данном случае это будет работать медленнее чем без OpenMP  Однако если основные вычисления будут вне critical - то вполне.

Ещё интересуют пару моментов.

Так, "пара моментов" (типа "детали")  Да там еще ничего и не начиналось. Настоящее распараллеливание очень далеко от резвого создания потоков в Qt. Мало не покажется.

[__Heaven__]

О, спасибо. Мне это пригодится.

У меня имеется обработка с помощью #pragma omp parallel for.
Как будет правильнее отображать прогресс (со значением -1)?
Я имею в виду, как обойти блокировку интерфейса. Нужно вынести вычисления в QThread? OpenMP не сунется в главный поток?

[Igors]

О, спасибо. Мне это пригодится.

У меня имеется обработка с помощью #pragma omp parallel for.
Как будет правильнее отображать прогресс (со значением -1)?
Я имею в виду, как обойти блокировку интерфейса. Нужно вынести вычисления в QThread? OpenMP не сунется в главный поток?

Используйте

#pragma omp master

[__Heaven__]

Можно подробнее?
Есть 2 класса MainWindow и Solver. Первый вызывает метод второго и показывает прогресс. В методе Solver прописан #pragma omp parallel for.
Куда вписывается #pragma omp master?

[Igors]

Можно подробнее?
Есть 2 класса MainWindow и Solver. Первый вызывает метод второго и показывает прогресс. В методе Solver прописан #pragma omp parallel for.
Куда вписывается #pragma omp master?

Псевдокод

Код

C++ (Qt)
void Solver::CalcParallel( void )
{
  QAtomicInt numDone = 0;
 
#pragma omp parallel for
  for (int i = 0; i < data.size; ++i) {
   DoCalc(data[i]);
   ++numDone;
 
#pragma omp master
   mainWindow->UpdateNumDone(numDone);
  }
}