У меня есть цикл, который работает с объектами и функциями класса. Также он рассчитывает несколько значений суммы. Я пробовал провести параллель с OpenMP:
Network net = *m_pNetwork;
TrainingSet tran = trainingSet;
omp_set_num_threads(4);
#pragma omp parallel for reduction(+:MSE, incorrectEntries) firstprivate(tran, net) lastprivate(net) private(outputIdx)
for (int i = 0; i < tran.size(); i++)
{
net->Evaluate(tran[i].m_inputs);
Backpropagate(tran[i].m_expectedOutputs);
// Check all outputs from neural network against desired values
bool resultCorrect = true;
for (outputIdx = 0; outputIdx < net->m_numOutputs; outputIdx++)
{
if (net->m_clampedOutputs[outputIdx] != tran[i].m_expectedOutputs[outputIdx])
{
resultCorrect = false;
}
MSE += pow((net->m_outputNeurons[outputIdx] - tran[i].m_expectedOutputs[outputIdx]), 2);
}
if (!resultCorrect)
{
//#pragma omp atomic
incorrectEntries++;
}
}
*m_pNetwork = net;
Моя проблема в том, что значения суммы одинаковы на каждой итерации. Так что я сделал неправильно?
@DanielLangr ага, это глупая ошибка, извините. Теперь заменил Network * net = m_pNetwork ----> Network net = * m_pNetwork. Новая проблема: значения суммы одинаковы на каждой итерации.
Понятия не имею, что это за значения суммы. Однако обратите внимание, что теперь net будет после параллельного цикла установлен на один частный net потока, который запускает последнюю итерацию. Это то, что ты хочешь? (См. Документацию lastprivate.)
@DanielLangr такие же значения без предложения lastprivate
Я считаю, что программирование, пытаясь понять, работает ли оно, - не лучший подход. Прочтите какую-нибудь хорошую книгу об OpenMP, или его документацию, или несколько руководств, прежде чем использовать его.
@DanielLangr Моя проблема теперь в объявлении переменной "net". С объявлением указателя последовательный алгоритм работал верно, теперь он работает как параллельный: все время одни и те же значения суммы.
Я никогда не видел, чтобы переменная объявлялась одновременно как firstprivate и lastprivate, и это вполне может быть незаконным ... хотя я не могу найти документ, который явно разрешает или запрещает это. lastprivate в любом случае мало используется, так как значение, скопированное обратно, будет значением из последнего завершенного потока. Какой поток это будет, обычно не контролируется.
Предложение atomic для увеличения incorrectEntries не требуется, поскольку оно объявлено с атрибутом совместного использования данных reduction (т.е. в каждом потоке есть частная копия переменной, и все данные будут безопасно суммироваться в конце).
parallel firstprivate lastprivate должно работать, но его лучше избегать, хотя бы для достижения ожидаемой производительности. Для omp simd функция firstprivate недоступна. Для его поддержки использовались устаревшие директивы Intel из предыдущих версий omp simd, но firstprivate lastprivate был отброшен на пути к требованию стандартного использования OpenMP.





net- это указатель. В параллельной секции каждый поток имеет свою собственную копиюnet, однако все они указывают на один и тот же объект.Network::evaluateпотокобезопасен?