Распараллеливание

@Andy_Coldfield · Регистрация: 25.11.2017

Студворк — интернет-сервис помощи студентам

Подскажите, что не так. Есть массив из 13 элементов, мне нужно разбить на три блока, один блок может быть неполный. При этом чтоб была обработка размера последнего блока. И получит сумму каждого блока. Если запускаю без распараллеливания, то все считается правильно. Когда начинаю параллелить на уровне блока for, то программа постоянно выдаёт мусор. В чем проблема может быть, вроде все правильно...

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
#include <omp.h>
#include <iostream>
 
using namespace std;
 
void xor(const int* a, int size, int *res)
{
int temp = 0;
for(int j =0; j < size; j++) temp = temp + a[j];
*res=0;
}
int main()
{
int m1[13] = {78,90,34,78,123,43,89,111,17,10,67,80,123};
int result [3]={0};
int i =0, size =0, length =5;
omp_set_num_threads(omp_get_num_procs());
#pragma omp parallel for 
for(i =0; i < 3; i++)
{
if(i == 2) size = 3; else size = 5;
xor(m1+i*length, size, result+i);
}
return 0;
}

Добавлено через 44 секунды
Ну вот мне удалось с помощью остановки потока

Добавлено через 19 секунд
Но не знаю насколько это правильно или корректно

Добавлено через 3 минуты

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
#include <omp.h>
#include <iostream>
#include <mutex>
 
using namespace std;
std :: mutex g_lock;
void xor(const int* a, int size, int *res)
{
int temp = 0;
for(int j =0; j < size; j++) temp = temp + a[j];
*res=0;
}
int main()
{
int m1[13] = {78,90,34,78,123,43,89,111,17,10,67,80,123};
int result [3]={0};
int i =0, size =0, length =5;
omp_set_num_threads(omp_get_num_procs());
#pragma omp parallel for 
for(i =0; i < 3; i++)
{
g_lock.lock();
if(i == 2) size = 3; else size = 5;
xor(m1+i*length, size, result+i);
g_lock.unlock();
}
return 0;
}

@abakankmf · 16.03.2020, 10:07

Код здесь ни причем:
#include <omp.h>
....
int main()
{

return 0;
}
Такой вот код. В VS2019 как только в свойствах проекта ставлю использовать /openmp,
появляется сообщение об ошибке про двухэтапный поиск имен. Сегодня попробовал создать
пустой проект в VS2017, сообщение о такой ошибке появляется, но с другим кодом, в итоге
проект все-таки создается.

@oleg-m1973 · 16.03.2020, 10:28

Сообщение от abakankmf

Сегодня попробовал создать
пустой проект в VS2017, сообщение о такой ошибке появляется, но с другим кодом, в итоге
проект все-таки создается.

В 17-й студии такой код прекрасно компилируется, без ошибок. В проекте Console App

@Andy_Coldfield · 13.07.2020, 13:01 **[ТС]**

oleg-m1973, а такой момент ещё интересен. А что если поток у меня не меняется?? Постоянно одно значение.... но при этом программа не выполняется три раза через цикл...

@oleg-m1973 · 13.07.2020, 13:20

Сообщение от Andy_Coldfield

oleg-m1973, а такой момент ещё интересен. А что если поток у меня не меняется?? Постоянно одно значение.... но при этом программа не выполняется три раза через цикл...

В смысле, поток не меняется? Что-то, наверное, не так сделал, покажи код

@Andy_Coldfield · 13.07.2020, 17:53 **[ТС]**

oleg-m1973, просто lock не добавил, и удивился что в одном потоке крутится все.

Добавлено через 44 секунды
oleg-m1973, а как с ерор с3107 бороться при компиляции...

@oleg-m1973 · 13.07.2020, 17:58

Сообщение от Andy_Coldfield

oleg-m1973, а как с ерор с3107 бороться при компиляции...

Покажи код

Сообщение от Andy_Coldfield

oleg-m1973, просто lock не добавил, и удивился что в одном потоке крутится все.

У тебя omp? Скорее всего она не включена в опциях компилятора

@Andy_Coldfield · 14.07.2020, 13:24 **[ТС]**

oleg-m1973, все было включено, но вот лок и анлок ещё добавил и заработало корректно. А как скопировать данные из структуры в массив?

@Andy_Coldfield · 22.07.2020, 17:16 **[ТС]**

oleg-m1973, возник интересный вопрос. У меня когда программа работает с большим объемом данных то время когда она выполняется как однопоточное или многопоточное, то есть на одном или трём потоках то время не особо отличается...

@oleg-m1973 · 22.07.2020, 17:18

Сообщение от Andy_Coldfield

oleg-m1973, возник интересный вопрос. У меня когда программа работает с большим объемом данных то время когда она выполняется как однопоточное или многопоточное, то есть на одном или трём потоках то время не особо отличается...

Так распараллелил значит, криво

@Andy_Coldfield · 23.07.2020, 22:32 **[ТС]**

oleg-m1973, оставил команду lock. А когда ее использую то потолки реализуются последовательно.

Добавлено через 2 минуты
oleg-m1973, а не подскажешь как эту задачу реализовать в виде дерева...

@oleg-m1973 · 23.07.2020, 22:43

Сообщение от Andy_Coldfield

oleg-m1973, а не подскажешь как эту задачу реализовать в виде дерева...

В смысле, какого ещё дерева? Я ж тебе вроде показывал здесь, как её сделать без open-mp.
C omp, наверное, лучше не извращаться, не разбивать массив на блоки, а сделать обычный цикл c reduction https://habr.com/ru/company/intel/blog/88574/

@Andy_Coldfield · 24.07.2020, 10:30 **[ТС]**

oleg-m1973, а что такое reduction?

@oleg-m1973 · 24.07.2020, 11:13

Сообщение от Andy_Coldfield

oleg-m1973, а что такое reduction?

Я ж скинул ссылку, там вроде описано, что такое reduction

@Andy_Coldfield · 24.07.2020, 16:27 **[ТС]**

oleg-m1973, а для экономии места, я могу сгенерировать массив произвольной большой длины и передать указатель на массив, чтоб его полностью не копировать в функцию.

@oleg-m1973 · 24.07.2020, 17:01

Сообщение от Andy_Coldfield

oleg-m1973, а для экономии места, я могу сгенерировать массив произвольной большой длины и передать указатель на массив, чтоб его полностью не копировать в функцию.

Ну да, так обычно и делают

@Andy_Coldfield · 30.07.2020, 15:04 **[ТС]**

oleg-m1973, а как определить количество потоков для распараллеливания?

@oleg-m1973 · 30.07.2020, 15:52

Сообщение от Andy_Coldfield

oleg-m1973, а как определить количество потоков для распараллеливания?

Просто ставишь какое хочешь и всё. Например по количеству процессоров, std::thread::hardware_concurrency

@Andy_Coldfield · 30.07.2020, 17:11 **[ТС]**

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

@oleg-m1973 · 30.07.2020, 17:13

Сообщение от Andy_Coldfield

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

Очевидно, что если ты поставишь количество потоков равное количеству процессоров/ядер, то ни один не будет простаивать

@Andy_Coldfield · 31.07.2020, 13:13 **[ТС]**

oleg-m1973, а как вывести количество процессоров?

C++
1
cout >> thread::hardware_concurrency>> endl;

У меня каждый раз разное значение выводится..

Новые блоги и статьи Все статьи Все блоги /
Перемещение выделенных строк ТЧ из одного документа в другой Maks 30.03.2026 Реализация из решения ниже выполнена на примере нетипового документа "ВыдачаОборудованияНаСпецтехнику" с единственной табличной частью "ОборудованиеИКомплектующие" разработанного в конфигурации КА2. . . .	Functional First Web Framework Suave DevAlt 30.03.2026 Sauve. IO Апнулись до NET10. Из зависимостей один пакет, работает одинаково хорошо как в режиме проекта так и в интерактивном режиме. из сложностей - чисто функциональный подход. Решил. . .	Автоматическое создание документа при проведении другого документа Maks 29.03.2026 Реализация из решения ниже выполнена на нетиповых документах, разработанных в конфигурации КА2. Есть нетиповой документ "ЗаявкаНаРемонтСпецтехники" и нетиповой документ "ПланированиеСпецтехники". В. . .	Настройка движения справочника по регистру сведений Maks 29.03.2026 Решение ниже реализовано на примере нетипового справочника "ТарифыМобильнойСвязи" разработанного в конфигурации КА2, с целью учета корпоративной мобильной связи в коммерческом предприятии. . . .
Автозаполнение реквизита при выборе элемента справочника Maks 27.03.2026 Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. При выборе "Спецтехники" (Тип Справочник. Спецтехника), заполняется. . .	Сумматор с применением элементов трёх состояний. Hrethgir 26.03.2026 Тут. https:/ / fips. ru/ EGD/ ab3c85c8-836d-4866-871b-c2f0c5d77fbc Первый документ красиво выглядит, но без схемы. Это конечно не даёт никаких плюсов автору, но тем не менее. . . всё может быть. . .	Автозаполнение реквизитов при создании документа Maks 26.03.2026 Программный код из решения ниже размещается в модуле объекта документа, в процедуре "ПриСозданииНаСервере". Алгоритм проверки заполнения реализован для исключения перезаписи значения реквизита,. . .	Команды формы и диалоговое окно Maks 26.03.2026 1. Команда формы "ЗаполнитьЗапчасти". Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. В качестве источника данных. . .

@abakankmf 0 / 0 / 0 Регистрация: 02.06.2015 Сообщений: 17
	16.03.2020, 10:07
	Код здесь ни причем: #include <omp.h> .... int main() { return 0; } Такой вот код. В VS2019 как только в свойствах проекта ставлю использовать /openmp, появляется сообщение об ошибке про двухэтапный поиск имен. Сегодня попробовал создать пустой проект в VS2017, сообщение о такой ошибке появляется, но с другим кодом, в итоге проект все-таки создается. 0

@Andy_Coldfield 21 / 19 / 6 Регистрация: 25.11.2017 Сообщений: 708
	13.07.2020, 13:01 [ТС]
	oleg-m1973, а такой момент ещё интересен. А что если поток у меня не меняется?? Постоянно одно значение.... но при этом программа не выполняется три раза через цикл... 0

@Andy_Coldfield 21 / 19 / 6 Регистрация: 25.11.2017 Сообщений: 708
	13.07.2020, 17:53 [ТС]
	oleg-m1973, просто lock не добавил, и удивился что в одном потоке крутится все. Добавлено через 44 секунды oleg-m1973, а как с ерор с3107 бороться при компиляции... 0

@Andy_Coldfield 21 / 19 / 6 Регистрация: 25.11.2017 Сообщений: 708
	14.07.2020, 13:24 [ТС]
	oleg-m1973, все было включено, но вот лок и анлок ещё добавил и заработало корректно. А как скопировать данные из структуры в массив? 0

@Andy_Coldfield 21 / 19 / 6 Регистрация: 25.11.2017 Сообщений: 708
	22.07.2020, 17:16 [ТС]
	oleg-m1973, возник интересный вопрос. У меня когда программа работает с большим объемом данных то время когда она выполняется как однопоточное или многопоточное, то есть на одном или трём потоках то время не особо отличается... 0

@Andy_Coldfield 21 / 19 / 6 Регистрация: 25.11.2017 Сообщений: 708
	23.07.2020, 22:32 [ТС]
	oleg-m1973, оставил команду lock. А когда ее использую то потолки реализуются последовательно. Добавлено через 2 минуты oleg-m1973, а не подскажешь как эту задачу реализовать в виде дерева... 0

@Andy_Coldfield 21 / 19 / 6 Регистрация: 25.11.2017 Сообщений: 708
	24.07.2020, 10:30 [ТС]
	oleg-m1973, а что такое reduction? 0

@Andy_Coldfield 21 / 19 / 6 Регистрация: 25.11.2017 Сообщений: 708
	24.07.2020, 16:27 [ТС]
	oleg-m1973, а для экономии места, я могу сгенерировать массив произвольной большой длины и передать указатель на массив, чтоб его полностью не копировать в функцию. 0

@Andy_Coldfield 21 / 19 / 6 Регистрация: 25.11.2017 Сообщений: 708
	30.07.2020, 15:04 [ТС]
	oleg-m1973, а как определить количество потоков для распараллеливания? 0

@Andy_Coldfield 21 / 19 / 6 Регистрация: 25.11.2017 Сообщений: 708
	30.07.2020, 17:11 [ТС]
	oleg-m1973, мне просто нужно узнать на какое количество потоков я могу раскидать, чтоб они все параллельно работали, и не было случая, чтоб один из них простаивал... 0