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

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

17.01.2020, 17:05. Показов 12168. Ответов 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
 Аватар для Annemesski
2687 / 1345 / 484
Регистрация: 08.11.2016
Сообщений: 3,733
31.07.2020, 13:42
Студворк — интернет-сервис помощи студентам
Andy_Coldfield,
C++
1
cout << thread::hardware_concurrency() << endl;
это функция, не забываем про скобки, и операторы ввода/вывода не путаем.
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
31.07.2020, 14:25
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, а как вывести количество процессоров?
thread::hardware_concurrency()
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
04.08.2020, 09:50  [ТС]
oleg-m1973, а вот ещё возник такой вопрос, могу ли я когда распараллеливаю кидать идентификатор(счётчик) в каждый поток. Но чтоб ну мерцания была сквозная...
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
04.08.2020, 11:38
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, а вот ещё возник такой вопрос, могу ли я когда распараллеливаю кидать идентификатор(счётчик) в каждый поток. Но чтоб ну мерцания была сквозная...
Да, можешь. Думаю, тебе здесь понадобится ссылка на std::atomic
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
04.08.2020, 12:06  [ТС]
oleg-m1973, а можно пример кода как этобудет выглядеть... просто немного непонятно как он работает...
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
04.08.2020, 12:15
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, а можно пример кода как этобудет выглядеть... просто немного непонятно как он работает...
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
        std::atomic<size_t> n{0};
        std::vector<std::thread> threads;
        for (size_t i = std::thread::hardware_concurrency(); i > 0; --i)
            threads.emplace_back([&n]()
            {
                for (size_t i = 0; i < 10; ++i)
                    ++n;
            });
 
        for (auto &thread: threads)
            thread.join();
 
        std::cout << n << std::endl;
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
11.08.2020, 12:08  [ТС]
oleg-m1973, а не подскажешь в библиотеке boost ест ли типы данных длиной 512 бит?
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
11.08.2020, 12:55
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, а не подскажешь в библиотеке boost ест ли типы данных длиной 512 бит?
Имеешь имеешь ввиду операции с 512-битными целыми?
Не знаю. А зачем тебе?
0
653 / 466 / 183
Регистрация: 23.04.2019
Сообщений: 1,987
11.08.2020, 14:24
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
ест ли типы данных длиной 512 бит?
точно есть на 128, скорее всего есть на 512
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
11.08.2020, 14:28
Цитата Сообщение от AndryS1 Посмотреть сообщение
точно есть на 128, скорее всего есть на 512
Не факт. 128-битная арифметика ещё худо-бедно поддерживается процессором, в 512-битная точно нет
0
653 / 466 / 183
Регистрация: 23.04.2019
Сообщений: 1,987
11.08.2020, 14:29
Цитата Сообщение от oleg-m1973 Посмотреть сообщение
Не факт
We can use either int128_t, int256_t, int512_t or int1024_t data type according to your requirement.
Примеры с этим тут
0
19501 / 10106 / 2461
Регистрация: 30.01.2014
Сообщений: 17,825
11.08.2020, 16:12
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
в библиотеке boost ест ли типы данных длиной 512 бит?
Не компилируется long long long
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
24.10.2020, 13:09  [ТС]
oleg-m1973, не подскажешь как распараллелить несколько циклов...
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
for(size_t i =0; i < count; i++)
{
for(size_t ii=i+1; ii < count; ii++)
{
u8 *temp = new [length];
foo(temp, M[i], M[ii], counter);
for(size_t iii = ii+1; iii <count; iii++)
{
u8 *temp_2 = new [length];
foo(temp_2, M[ii], M[iii], counter);
delete [] temp_2;
}
delete t[] temp_1;
}
delete [] temp;
}
0
76 / 68 / 10
Регистрация: 11.07.2016
Сообщений: 320
24.10.2020, 18:02
Уточни, что такое M, что такое counter и что делает foo().
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
24.10.2020, 18:08
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, не подскажешь как распараллелить несколько циклов...
Зачем ты там на каждую итерацию выделяешь буферы, одого размера? Выдели их один раз до всех циклов
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
24.10.2020, 23:44  [ТС]
oleg-m1973, это позволит сэкономить время? И как распараллелить на пять циклов??

Добавлено через 4 минуты
Zirak, М это двумерный массив, функция преобразует два массива в один и выводит файл, а коврики это уникальный идентификатор для имени каждого файла.

Добавлено через 1 час 59 минут
Zirak, oleg-m1973, я просто так и не нашёл как параллелить поток в потоке...
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
25.10.2020, 09:29  [ТС]
А как количество потоков добавить на каждый цикл, или он сам раскидывает, вот этот момент я не до конца понял....
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
#pragma omp parallel for colapse(5)
for(size_t i =0; i < count; i++)
{
for(size_t ii=i+1; ii < count; ii++)
{
u8 *temp = new [length];
foo(temp, M[i], M[ii], counter);
for(size_t iii = ii+1; iii <count; iii++)
{
u8 *temp_2 = new [length];
foo(temp_2, M[ii], M[iii], counter);
delete [] temp_2;
}
delete t[] temp_1;
}
delete [] temp;
}
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
25.10.2020, 11:39
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
#pragma omp parallel for colapse(5)
У тебя вроде три вложенных цикла, поэтому надо делать colapse(3). А в твоём случае, возможно, и colapse(2).
Что ты тут вообще пытаешься сделать? Покажи функцию foo. Что-то сомневаюсь, что твой код после "распараллеливания" будет работать быстрее, чем без него.
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
25.10.2020, 16:24  [ТС]
Вот код я хочу распараллелить)
oleg-m1973,
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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
#define _CRT_SECURE_NO_WARNINGS
#include <cstdio>
#include<iostream>
#include <random>
#include <fstream>
using namespace std;
size_t counter = 0;
void output(uint8_t* a, size_t length, size_t &c)
{
    char path[200];
    char adress[200] = "C:\\Out\\data.%d.bin";
    sprintf(path, adress, c);
    ofstream out(path, ios::app | ios::binary);
    for (size_t i = 0; i < length; i++)
        out << a[i];
    c++;
}
void foo(uint8_t *a, uint8_t *b, uint8_t *c, size_t length, size_t &count)
{
    for (int j = 0; j < length; j++)
        a[j] = b[j] ^ c[j];
    output(a, length, count);
}
int main()
{
    size_t row = 10;
    size_t cols = 5;
    uint8_t** c = new uint8_t *[row];
    for (size_t i = 0; i < row; i++)
        c[i] = new uint8_t[cols];
    for (size_t i = 0; i < cols; i++)
        for (size_t j = 0; j < cols; j++)
        {
            c[i][j] = rand();
            //cout <<(int) c[i][j] << " ";
        }
    
//#pragma omp parallel for colapse(3)
    for (size_t i = 0; i < row; i++)
    {
        for (size_t ii = i + 1; ii < row; ii++)
        {
            uint8_t* temp = new uint8_t [cols];
            foo(temp, c[i], c[ii], cols, counter);
            for (size_t iii = ii + 1; iii < row; iii++)
            {
                uint8_t* temp_2 = new uint8_t [cols];
                foo(temp_2, temp, c[iii], cols, counter);
                delete[] temp_2;
            }
            delete [] temp;
        }
    }
    return 0;
}
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
25.10.2020, 16:52
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
Вот код я хочу распараллелить)
А какой у тебя компилятор?
C++
1
2
warning C4849: OpenMP 'collapse' clause ignored in 'parallel for' directive
error C3016: 'i': index variable in OpenMP 'for' statement must have signed integral type
Добавлено через 4 минуты
C++
1
2
3
4
5
6
7
8
9
10
    std::unique_ptr<uint8_t[]> temp(new uint8_t [cols]);
    std::unique_ptr<uint8_t[]> temp_2(new uint8_t [cols]);
    for (size_t i = 0; i < row; i++)
        for (size_t ii = i + 1; ii < row; ii++)
        {
            foo(temp.get(), c[i], c[ii], cols, counter);
            for (size_t iii = ii + 1; iii < row; iii++)
                foo(temp_2.get(), temp.get(), c[iii], cols, counter);
        }
    }
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
25.10.2020, 16:52

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

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

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

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

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


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

Или воспользуйтесь поиском по форуму:
60
Ответ Создать тему
Новые блоги и статьи
Сезонность и суточность закисления почв
anaschu 04.07.2026
200 часов это все равно моловато. Есть ситуации, но нестандартные, когда смена происходит за 5 лет. Но обычно это 50 лет и более. Наверное, закисление почвы происходит сезонно в средней. . .
В чем ценность человеческого опыта в глобальном смысле?
kumehtar 03.07.2026
Возможно, ценность человека не в том, что он однажды достигает мудрости, а в том, что он становится носителем карты пути. Он знает не только истину, но и последовательность внутренних изменений,. . .
интеграция AnyLogic с самописным REST API и переход на Odoo
anaschu 03.07.2026
Успешная интеграция AnyLogic с самописным REST API и переход на промышленную Odoo WMS Сегодня проделал огромный путь от простой симуляции физических процессов до построения полноценной. . .
Поиск всех путей на ориентированном графе. Linux
dcc0 02.07.2026
Переработка старого кода из моей статьи. Через несколько переработок от PHP кода к C89 (надеюсь, 89). Но довольно запутанно получилось. Код для Linux. Но если убрать time и то, что с ним. . .
Сам себя обучал rest api
anaschu 02.07.2026
Педагогический лайфхак: Почему чистый REST API для ученика намного круче, чем готовые библиотеки Когда мы отказались от капризного JAR-файла AnyLogic и переписали код на стандартный HttpClient,. . .
rest api anylogic - выполнение модели на своём русском сайте
anaschu 02.07.2026
Как подружиться с AnyLogic Cloud API, победить провайдеров и развернуться Java-бэкенд в Docker на бесплатном хостинге: Двухдневный лог борьбы Всем привет! Хочу поделиться свежим (и довольно. . .
Где деньги лежат
kumehtar 02.07.2026
Это - японская подводная лодка I-52 (тип C2, кодовое имя Momi) вышла из Японии в марте 1944 года с миссией в оккупированную немцами Францию (Лорьян). Это была одна из «Янаги»-миссий по обмену. . .
Krabik для WoW 3.3.5a, многоязычный
AmbA 02.07.2026
Допилил бота, думаю что окончательно. Изменения: - добавлена многоязычность - добавлено снятие скриншотов - добавлено поддержание бафов хождения по воде (для жреца, дк и шамана) - и так, по. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru