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

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

17.01.2020, 17:05. Показов 11706. Ответов 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
Ответ Создать тему
Новые блоги и статьи
Thinkpad X220 Tablet — это лучший бюджетный ноутбук для учёбы, точка.
Programma_Boinc 23.12.2025
Thinkpad X220 Tablet — это лучший бюджетный ноутбук для учёбы, точка. Рецензия / Мнение/ Перевод https:/ / **********/ gallery/ thinkpad-x220-tablet-porn-gzoEAjs . . .
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