Форум программистов, компьютерный форум, киберфорум
С++ для начинающих
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
 
Рейтинг 4.81/57: Рейтинг темы: голосов - 57, средняя оценка - 4.81
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708

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

17.01.2020, 17:05. Показов 11708. Ответов 100
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Подскажите, что не так. Есть массив из 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;
}
0
cpp_developer
Эксперт
20123 / 5690 / 1417
Регистрация: 09.04.2010
Сообщений: 22,546
Блог
17.01.2020, 17:05
Ответы с готовыми решениями:

Распараллеливание
Всем добрый вечер. Если кто знает подскажите,мне надо распараллелить перемножение матриц,преподаватель сказал,что это делается просто с...

распараллеливание
Скажите, кто-нибудь занимался распараллеливанием в си++? В моих попытках что-либо распараллелить через omp все выходило только в несколько...

Распараллеливание циклов
Возникли трудности с освоением OpenMP Непонимаю, почему если закоментировать вот этот фрагмент кода, то программа работает вы разы...

100
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
25.10.2020, 16:54  [ТС]
Студворк — интернет-сервис помощи студентам
oleg-m1973, вот у меня с3015 и с3006 ошибки
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
25.10.2020, 17:05
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, вот у меня с3015 и с3006 ошибки
Попробуй вот так
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
#pragma omp parallel 
{
    std::unique_ptr<uint8_t[]> temp(new uint8_t [cols]);
    std::unique_ptr<uint8_t[]> temp_2(new uint8_t [cols]);
    //printf("%d\n", omp_get_thread_num());
#pragma omp for //collapse(2)
    for (int i = 0; i < row; i++)
    {
        //printf("%d> %d\n", omp_get_thread_num(), i);
        for (int ii = i + 1; ii < row; ii++)
        {
            //printf("%d> %d, %d\n", omp_get_thread_num(), i, ii);
            foo(temp.get(), c[i], c[ii], cols, counter);
            for (int iii = ii + 1; iii < row; iii++)
                foo(temp_2.get(), temp.get(), c[iii], cols, counter);
        }
    }
}
collapse возможно не поддерживается в visual C++
1
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
25.10.2020, 18:26  [ТС]
oleg-m1973, vs2019

Добавлено через 1 час 20 минут
oleg-m1973,
Ошибка C3005 colapse: непредвиденная лексема в директиве OpenMP "for"
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
25.10.2020, 18:28
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
Ошибка C3005 colapse: непредвиденная лексема в директиве OpenMP "for"
collapse
1
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
25.10.2020, 18:30  [ТС]
oleg-m1973, закомментировал colapse. И вывод потока сделал в функции output. И получилось что там вывел числа от 0 до 7 это как я понимаю потоки?
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
25.10.2020, 18:33
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, закомментировал colapse. И вывод потока сделал в функции output. И получилось что там вывел числа от 0 до 7 это как я понимаю потоки?
Возможно. Зависит от того, что именно ты вывел.
omp_get_thread_num это номер текущего потока.
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
25.10.2020, 19:13  [ТС]
oleg-m1973, его как раз и выводил) Спасибо еще раз) Вот только я не совсем понял как работает collapse. Когда с одним циклом то можно выбрать количество потоков, а тут просто пишу collapse и все.
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
25.10.2020, 19:21
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, его как раз и выводил) Спасибо еще раз) Вот только я не совсем понял как работает collapse. Когда с одним циклом то можно выбрать количество потоков, а тут просто пишу collapse и все.
Насколько я понимаю, collapse объединяет несколько циклов в один и распараллеливает его.
Например
C++
1
2
3
4
#pragma omp for collapse(2)
for (int i = 0; i < N; ++i)
    for (int j = 0; j < M; ++j)
        arr[i][j];
выполнится аналогично (соответствующие индексы подставятся)
C++
1
2
3
#pragma omp for 
for (int i = 0; i < N * M; ++i)
    arr[i ......];
1
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
25.10.2020, 19:29  [ТС]
oleg-m1973, сейчас обратил внимание, что в папке у меня всего 151 файла, а номер последнего 157. Получается что итерация счетчика работает некорректно. Можно ли это поправить?

Добавлено через 32 секунды
oleg-m1973, это как глобальная переменная

Добавлено через 4 минуты
oleg-m1973, сейчас показал что в папке 140 файлов, последний с индексом 164. А в папке некоторые файлы пропущены.... То есть идет 0 потом 2,3, потом 6....
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
25.10.2020, 19:32
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, сейчас обратил внимание, что в папке у меня всего 151 файла, а номер последнего 157. Получается что итерация счетчика работает некорректно. Можно ли это поправить?
C++
1
2
3
4
5
6
7
8
9
10
11
12
std::atomic<size_t> counter = 0;
void output(uint8_t* a, size_t length, size_t &c)
{
    char path[200];
 
    const size_t n = ++c;
    sprintf(path, "C:\\Out\\data.%d.bin", n);
 
    ofstream out(path, ios::app | ios::binary);
    for (size_t i = 0; i < length; i++)
        out << a[i];
}
Добавлено через 2 минуты
Вернее
C++
1
2
3
4
5
6
7
8
9
10
11
12
std::atomic<size_t> counter{0};
void output(uint8_t* a, size_t length)
{
    char path[200];
 
    const size_t n = ++counter;
    sprintf(path, "C:\\Out\\data.%d.bin", n);
 
    ofstream out(path, ios::app | ios::binary);
    for (size_t i = 0; i < length; i++)
        out << a[i];
}
1
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
25.10.2020, 22:00  [ТС]
oleg-m1973, только
C++
1
std::atomic<size_t> counter{0};
здесь статик подчеркивается...

Добавлено через 24 минуты
C++
1
#include <atomic>
пофиксил)

Добавлено через 10 минут
oleg-m1973, спасибо) пойду читать матчасть далее))

Добавлено через 2 минуты
oleg-m1973, а не подскажешь какую книгу по многопоточному программированию на русском, а то читать англоязычные источники трудновато, да и не всегда удается правильно понять материал и возникает много вопросов))
0
76 / 68 / 10
Регистрация: 11.07.2016
Сообщений: 320
25.10.2020, 22:29
Параллельное программирование в действии, Уильямс.
1
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
26.10.2020, 10:59  [ТС]
oleg-m1973, а на vs2012 выдаёт ошибки с3005 и с3014...
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
26.10.2020, 12:10
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, а на vs2012 выдаёт ошибки с3005 и с3014...
Покажи код и ошибки

Добавлено через 13 минут
Установи 2019, нафига тебе эта 2012 сдалась?
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
29.10.2020, 14:28  [ТС]
oleg-m1973,
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
#include<iostream>
#include<omp.h>
#using namespace std;
int main()
{
 
#pragma omp parallel
{
    #pragma omp for
    for( int i=0; i < 10;++i )
    {
cout<<i<<“ “<<omp_get_threads_num()<<endl;
    }
}
return 0;
}
Выдаётся сообщение undefined reference to omp_get.... собираю из под линукса
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
29.10.2020, 15:05
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
Выдаётся сообщение undefined reference to omp_get.... собираю из под линукса
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
cout<<i<<“ “<<omp_get_threads_num()<<endl;
omp_get_thread_num
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
03.11.2020, 10:29  [ТС]
oleg-m1973, собираю проект на убунте 16.04. Пишет
1) warning ignoring #pragma omp parallel
2) use of deleted function “std :: atomic<long unsigned int>:const std::atomic<long unsigned int>&)

Добавлено через 2 минуты
oleg-m1973, openmp не подключил при сборке)
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
03.11.2020, 10:31
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
1) warning ignoring #pragma omp parallel
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
2) use of deleted function “std :: atomic<long unsigned int>:const std::atomic<long unsigned int>&)

Покажи код

Добавлено через 34 секунды
https://gcc.gnu.org/onlinedocs... penMP.html
1
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
03.11.2020, 11:37  [ТС]
oleg-m1973, я неправильно проиницилизировал
C++
1
atomic<size_t> counter{0};
Так собралось и все гут)) Спасибо)
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
06.11.2020, 14:50  [ТС]
oleg-m1973, а что если мне надо все в один файл вывести, то есть каждый поток подсчитывает и последовательно записывает в выходной файл. С помощью mutex это делается?
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
06.11.2020, 14:50
Помогаю со студенческими работами здесь

Распараллеливание вычислений
Вычисляю произведение матриц несколькими потоками (количество задаётся пользователем). Потоки &quot;засыпают&quot; на 1 мс. При...

Распараллеливание программы
Помогите эту последовательную программу распараллелить на параллельных 2 процесса. #include &lt;iostream&gt; #include&lt;thread&gt; ...

Распараллеливание вычислений
Здравствуйте. Может кто сможет подсказать как мне решить следующую задачу: необходимо распараллелить следующий последовательный код:...

Странное распараллеливание
Добрый вечер, коллеги. У меня следующая проблема. Преподаватель сказал распараллелить программу, обрабатывающую изображения в папке....

Распараллеливание циклов
Доброго времени суток. Возникла необходимость распараллелить один численный алгоритм средствами OpenMP. В частности в этом алгоритме...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
80
Ответ Создать тему
Новые блоги и статьи
Thinkpad X220 Tablet — это лучший бюджетный ноутбук для учёбы, точка.
Programma_Boinc 23.12.2025
Рецензия / Мнение/ Перевод Ниже машинный перевод статьи The Thinkpad X220 Tablet is the best budget school laptop period . Thinkpad X220 Tablet — это лучший бюджетный ноутбук для учёбы,. . .
PhpStorm 2025.3: WSL Terminal всегда стартует в ~
and_y87 14.12.2025
PhpStorm 2025. 3: WSL Terminal всегда стартует в ~ (home), игнорируя директорию проекта Симптом: После обновления до PhpStorm 2025. 3 встроенный терминал WSL открывается в домашней директории. . .
Как объединить две одинаковые БД Access с разными данными
VikBal 11.12.2025
Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.
Новый ноутбук
volvo 07.12.2025
Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro
Музыка, написанная Искусственным Интеллектом
volvo 04.12.2025
Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .
От async/await к виртуальным потокам в Python
IndentationError 23.11.2025
Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .
Поиск "дружественных имён" СОМ портов
Argus19 22.11.2025
Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .
Сколько Государство потратило денег на меня, обеспечивая инсулином.
Programma_Boinc 20.11.2025
Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .
Ломающие изменения в C#.NStar Alpha
Etyuhibosecyu 20.11.2025
Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .
Мысли в слух
kumehtar 18.11.2025
Кстати, совсем недавно имел разговор на тему медитаций с людьми. И обнаружил, что они вообще не понимают что такое медитация и зачем она нужна. Самые базовые вещи. Для них это - когда просто люди. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2025, CyberForum.ru