Помогите распараллелить цикл

[nata267]

Друзья, не могу найти инфу как распараллелить цикл. Любой цикл не важно. Например, такой:

Код:

for (int it = 0; it < numIterations; it++) {
 		for (int index = 0; index < cachedUserIDs.size(); index++) {
 			long userId = cachedUserIDs[index];
 			long itemId = cachedItemIDs[index];
			float rating = cachedValues[index];
 			updateParameters(userId, itemId, rating, currentLearningRate);
 		}
 		currentLearningRate *= learningRateDecay;
 	}

Только начинаю изучать многопоточность. Инструмент не важен. Главное чтобы это было не автоматическое распараллеливание как в OpenMP. Мне важен сам принцип распараллеливания. Как и где создавать потоки, мьютексы и т д как они обмпениваются значениями и переменными и.т.д.

[Vamireh]

Разбиваете numIterations на N отрезков
Да хоть наследуетесь от QThread, в конструктор передаете индексы начала и конца отрезка, а также указатель на общие данные
В перегруженном run() выполянете нужный вам код для этого отрезка
Создаете N экземпляров этого класса
Для каждого вызываете start()
Для каждого вызываете wait()

Если данные только читать, то можно как-то так. Если в данные надо что-то писать, то вдовесок в конструктор передаете указатель на мьютекс, а в методе run() перед записью его блокируйте, а после записи - разблокируйте.

Если очень грубо, то так.

[Vamireh]

Ну или создаете просто класс, который делает этот цикл, а в параметре метода - начальный и конечный индекс. В начале метода блокируете мьютекс, в конце - разблокруйте.
Наследуетесь от того же QThread, передаете указатель на экземпляр первого класса. И в run вызваете его для нужного интервала.
Опять создаете сколько нужно потоков, для всех start() и wait().

Я бы скорее по такой схеме делал.
 

[nata267]

Ну или создаете просто класс, который делает этот цикл, а в параметре метода - начальный и конечный индекс. В начале метода блокируете мьютекс, в конце - разблокруйте.
Наследуетесь от того же QThread, передаете указатель на экземпляр первого класса. И в run вызваете его для нужного интервала.
Опять создаете сколько нужно потоков, для всех start() и wait().

Я бы скорее по такой схеме делал.
 

Большое спасибо, попробую так

[OKTA]

Чтобы не мучиться с QThread, посмотрите в сторону QtConcurrentRun и вообще в http://qt-project.org/doc/qt-4.8/threads-qtconcurrent.html

[Vamireh]

Чтобы не мучиться с QThread, посмотрите в сторону QtConcurrentRun и вообще в http://qt-project.org/doc/qt-4.8/threads-qtconcurrent.html

Да, это гораздо проще, но:

Главное чтобы это было не автоматическое распараллеливание как в OpenMP. Мне важен сам принцип распараллеливания. Как и где создавать потоки, мьютексы и т д как они обмпениваются значениями и переменными и.т.д.

[nata267]

Может быть распараллеливать цикл - плохая идея? Может быть не любой цикл возможно распараллелить?

[Vamireh]

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

[Igors]

...Любой цикл не важно.
...Инструмент не важен.
...Мне важен сам принцип распараллеливания.

В действительности все это важно. "Любой цикл" - совершенно неверный подход. "Кластер" должен быть приличным чтобы распараллеливание имело смысл. Если делать самому то выглядит примерно так

- завести N ниток для параллельной работы, которые пока спят
- разбить задачи цикла на кучки, в простейшем случае дать каждой рабочей нитке примерно одинаковое число задач
- запустить каждую рабочую нитку дав ей "свои" задачи
- дождаться окончания работы каждой рабочей и усыпить ее

Реализовать это непросто, напр прямолинейное усыпление/пробуждение ниток может оказаться неприемлемо медленным. Поэтому надо подбирать инструмент. Я пользуюсь OpenMP и очень доволен. Qt аналог - QtConcurrent.

По поводу мутексов, обмена данными и.т.п. - это "синхронизация", отношение к распараллеливанию имеет косвенное.

[OKTA]

И добавлю к вышесказанному, что даже использование "автоматических" средств, как QtConcurrent и OpenMP не избавляет от необходимости использования средств синхронизации потоков, самостоятельной организации обмена данными между потоками и т.д. и т.д....