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

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

17.01.2020, 17:05. Показов 12170. Ответов 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
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
06.11.2020, 16:29
Студворк — интернет-сервис помощи студентам
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, а что если мне надо все в один файл вывести, то есть каждый поток подсчитывает и последовательно записывает в выходной файл. С помощью mutex это делается?
Да, нужно синхронизирать доступ к файлу, например при помощи std::mutex
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
09.11.2020, 10:37  [ТС]
oleg-m1973, у меня исключение выскочило Unhandled exception at 0x00c5ca5a. Access violation reading location.

Добавлено через 1 минуту
oleg-m1973, я так понимаю это ошибка связана с обращением к памяти?
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
09.11.2020, 10:54
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, у меня исключение выскочило Unhandled exception at 0x00c5ca5a. Access violation reading location.
Где?
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
09.11.2020, 11:17  [ТС]
oleg-m1973, в цикле когда перебираются комбинации

Добавлено через 22 секунды
oleg-m1973, в функции выхода(
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
09.11.2020, 11:49
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, в цикле когда перебираются комбинации
Покажи код
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
30.01.2021, 14:53  [ТС]
oleg-m1973, хочу сделать чтоб каждый поток выводил в свой файл.

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
#pragma omp parallel num_threads(8)
    {
        for (int i = 0; i < 10; i++)
        {
            cout << "Thread " << omp_get_thread_num() << endl;
            buffer += path;
            buffer += to_string(i);
            // cout << buffer << endl;
            ofstream f_out;
            f_out.open(buffer);
            f_out << "Success!" << endl;
            f_out << omp_get_thread_num() << endl;
            f_out << i << endl;
            for(int z = 0; z < 10; z++)
            {
                 f_out << rand() + i << endl;
            }
            f_out.close();
        }
    }
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
30.01.2021, 14:57
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, хочу сделать чтоб каждый поток выводил в свой файл.
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
buffer += to_string(i);
C++
1
buffer += to_string(omp_get_thread_num());
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
30.01.2021, 15:13  [ТС]
oleg-m1973, у меня всего 10 файлов должно создаться, а потоков восемь. А так будет только восемь файлов

Добавлено через 55 секунд
oleg-m1973, а если 10000 файлов надо или больше создать....
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
30.01.2021, 15:18
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, у меня всего 10 файлов должно создаться, а потоков восемь. А так будет только восемь файлов
C++
1
2
buffer += to_string(omp_get_thread_num() * 10);
buffer += to_string(i);
Добавлено через 1 минуту
А вообще, тебе точно цикл не нужно распараллеливать?
C++
1
2
3
4
#pragma omp parallel num_threads(8)
    {
#pragma omp for
        for (int i = 0; i < 10; i++)
Добавлено через 2 минуты
У тебя там файлы создаются 80 раз - в каждом из восьми потоков по десять раз. Каким образом из них нужно получить десять файлов?
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
30.01.2021, 15:37  [ТС]
oleg-m1973, Вообще-то создает только один Дата.4
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
int main(void)
{
    
    string path = "C:\\Out\\data.";
    string buffer;
#pragma omp parallel num_threads(4)
    {
#pragma omp for
        for (int i = 0; i < 10; i++)
        {
            cout << "Thread " << omp_get_thread_num() << endl;
            buffer += path;
            buffer += to_string(i);
            ofstream f_out;
            f_out.open(buffer);
            f_out << "Success!" << endl;
            f_out << omp_get_thread_num() << endl;
            f_out << i << endl;
            f_out.close();
        }
    }
    return 0;
}
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
30.01.2021, 15:39
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, Вообще-то создает только один Дата.4
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
buffer += path;
            buffer += to_string(i);
Потому что buffer один для всех. Сделай
C++
1
2
string buffer = path;
buffer += to_string(i);
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
30.01.2021, 15:42  [ТС]
oleg-m1973,
Почему 80? Сначала я указываю количество потоков, а потом сам цикл for распараллеливается по потокам

Добавлено через 1 минуту
oleg-m1973, так у меня так и написано...
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
30.01.2021, 15:43
Лучший ответ Сообщение было отмечено Andy_Coldfield как решение

Решение

Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
Почему 80? Сначала я указываю количество потоков, а потом сам цикл for распараллеливается по потокам
Потому что без #pragma omp for цикл не будет распараллеливаться и каждый поток выполнит его 10 раз, в смысле пройдёт от нуля до десяти.

Добавлено через 39 секунд
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, так у меня так и написано...
Где?
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
string buffer;
#pragma omp parallel num_threads(4)
    {
#pragma omp for
        for (int i = 0; i < 10; i++)
        {
            cout << "Thread " << omp_get_thread_num() << endl;
            buffer += path;
            buffer += to_string(i);
1
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
30.01.2021, 16:32  [ТС]
oleg-m1973, логично)) вот где я апшибся))

Добавлено через 47 минут
oleg-m1973, а как исправить неустранимую ошибку))
Неустранимая ошибка C1189
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
30.01.2021, 16:33
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
oleg-m1973, а как исправить неустранимую ошибку))
Неустранимая ошибка C1189
Наверное никак. Она же неустранимая.
Покажи код.
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
30.01.2021, 16:43  [ТС]
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
void kuz_encrypt_block(kuz_key_t *key, void *blk)
{
    int i;
    __m128i x;
 
    x = *((__m128i *) blk);
 
    for (i = 0; i < 9; i++) {
        x ^= *((__m128i *) &key->k[i]);
        x = kuz_pil_enc128[ 0][((uint8_t *) &x)[ 0]] ^
            kuz_pil_enc128[ 1][((uint8_t *) &x)[ 1]] ^
            kuz_pil_enc128[ 2][((uint8_t *) &x)[ 2]] ^
            kuz_pil_enc128[ 3][((uint8_t *) &x)[ 3]] ^
            kuz_pil_enc128[ 4][((uint8_t *) &x)[ 4]] ^
            kuz_pil_enc128[ 5][((uint8_t *) &x)[ 5]] ^
            kuz_pil_enc128[ 6][((uint8_t *) &x)[ 6]] ^
            kuz_pil_enc128[ 7][((uint8_t *) &x)[ 7]] ^
            kuz_pil_enc128[ 8][((uint8_t *) &x)[ 8]] ^
            kuz_pil_enc128[ 9][((uint8_t *) &x)[ 9]] ^
            kuz_pil_enc128[10][((uint8_t *) &x)[10]] ^
            kuz_pil_enc128[11][((uint8_t *) &x)[11]] ^
            kuz_pil_enc128[12][((uint8_t *) &x)[12]] ^
            kuz_pil_enc128[13][((uint8_t *) &x)[13]] ^
            kuz_pil_enc128[14][((uint8_t *) &x)[14]] ^
            kuz_pil_enc128[15][((uint8_t *) &x)[15]];
            
    }
    x ^= *((__m128i *) &key->k[9]);
 
    *((__m128i *) blk) = x;
}


Добавлено через 5 минут
oleg-m1973,
C++
1
2
3
#ifndef __SSE4_1__
#error "This version requires __SSE4_1__"
#endif
Подчеркивает error
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
30.01.2021, 16:45
Очевидно, проблема в том, что ты на вход передаёшь что-то кривое

Добавлено через 1 минуту
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
Подчеркивает error
Потому что нет такой директивы препроцессора
C++
1
2
3
#ifndef __SSE4_1__
static_assert(false, "This version requires __SSE4_1__");
#endif
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
30.01.2021, 16:55  [ТС]
oleg-m1973,
Кликните здесь для просмотра всего текста
https://github.com/mjosaarinen/kuznechik/

Я просто вот этот проект хочу собрать, и возникает ошибка 1189...
0
6772 / 4565 / 1844
Регистрация: 07.05.2019
Сообщений: 13,726
30.01.2021, 17:03
Цитата Сообщение от Andy_Coldfield Посмотреть сообщение
Я просто вот этот проект хочу собрать, и возникает ошибка 1189...
Возможно, проблема в том, что типы __m128i и w128_t различаются. Проверь, что они хотя бы одинакового размера
0
21 / 19 / 6
Регистрация: 25.11.2017
Сообщений: 708
11.03.2021, 14:05  [ТС]
oleg-m1973, а Если у меня счётчик выходит за границы типа инт, то как быть? Просто если делаю тип переменной счётчик unsigned int 64, то ошибка...
errorC3106
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
11.03.2021, 14:05

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

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

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

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

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


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

Или воспользуйтесь поиском по форуму:
100
Ответ Создать тему
Новые блоги и статьи
Сезонность и суточность закисления почв
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