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

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

17.01.2020, 17:05. Показов 12111. Ответов 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
Ответ Создать тему
Новые блоги и статьи
Взрослые отношения, и почему они не получаются
kumehtar 09.06.2026
Когда в детстве ребёнок не получает от родителей чего-то важного, он лишается не просто приятных переживаний, а основы для формирования определённых внутренних качеств и навыков. Если ребёнок не. . .
[golang] Worker Pool
alhaos 09.06.2026
Worker Pool Worker Pool — паттерн конкурентной обработки задач в Go. Суть: фиксированное количество горутин-воркеров читают задачи из общего канала и пишут результаты в общий канал результатов. . . .
[golang] Pipeline
alhaos 08.06.2026
Pipeline Pipeline — паттерн конкурентной обработки данных в Go. Суть: данные проходят через цепочку независимых стадий, каждая из которых работает в своей горутине и общается с соседями через. . .
Свет внутри себя
kumehtar 07.06.2026
Пусть это будет здесь lIs4oanZS9Y
Программа для com-порта
Uhbif79 05.06.2026
Всем привет, давно хотел изучить Qt, начинал, бросал, потом снова начинал. И сейчас вот смог написать свою первую программу. До этого имел опыт программирования микроконтроллеров, писал прошивки на. . .
Транскрипция 55-минутного видео через Whisper: WhisperDesktop облажался, спас Google Colab[
anaschu 01.06.2026
Понадобилось получить текст из свежезагруженного видео на YouTube. Казалось бы, задача на пять минут. Заняла полтора часа. Делюсь опытом — может кому пригодится последовательность решений. . . .
21 мат мед. Планы на развитие модели здравоСохранения
anaschu 01.06.2026
AnyLogic: план развития симуляционной модели рабочего коллектива — динамический абсентеизм, реальные данные, три сценария сравнения Продолжаю серию постов о дискретно-событийной модели рабочего. . .
20. Мат мед. Абсентеизм как отдельный тип простоя
anaschu 29.05.2026
Апдейт модели: исправленные баги, абсентеизм и новые механизмы Продолжаю развивать ранее описанную модель рабочего коллектива на AnyLogic. За последние несколько дней был проведён серьёзный. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru