Многопоточность в C++

@SenpaiVladian · Регистрация: 02.12.2019

Студворк — интернет-сервис помощи студентам

Всем привет! Помогите, пожалуйста с реализацией кода. С/С++ очень плохо знаю.

Первую часть сделал нормально, а вот со второй проблемки.
Задание: Общие и частные переменные в OpenMP: параметр reduction
1. Напишите программу, в которой две нити параллельно вычисляют
сумму чисел от 1 до N. Распределите работу по нитям с помощью оператора
if языка С. Для сложения результатов вычисления нитей воспользуйтесь
OpenMP-параметром reduction.
Входные данные: целое число N – количество чисел.
Выходные данные: каждая нить выводит свою частичную сумму в формате
«[Номер_нити]: Sum = <частичная_сумма>», один раз выводится общая
сумма в формате «Sum = <сумма>».
Пример входных и выходных данных
Входные данные
4
Выходные данные
[0]: Sum = 3
[1]: Sum = 7
Sum = 10
2*. Модифицируйте программу таким образом, чтобы она работала для k
нитей.
Входные данные: целое число k – количество нитей, целое число N – количество чисел.
Выходные данные: каждая нить выводит свою частичную сумму в формате
«[Номер_нити]: Sum = <частичная_сумма>», один раз выводится общая
сумма в формате «Sum = <сумма>».
Пример входных и выходных данных
Входные данные
2
4
Выходные данные
[0]: Sum = 3
[1]: Sum = 7
Sum = 10
Входные данные
2
2
Выходные данные
[0]: Sum = 1
[1]: Sum = 2
Sum = 3
Входные данные
3
2
Выходные данные
[0]: Sum = 1
[1]: Sum = 2
[2]: Sum = 0
Sum = 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
29
30
31
#include <omp.h>
#include <stdio.h>
 
void main()
{
    int n, i, k, nk,nk1, nk2, sum(0);
    printf("Enter an integer N: ");
    scanf_s("%d", &n);
    printf("Enter an integer number of threads k: ");
    scanf_s("%d", &k);
    
    #pragma omp parallel reduction(+:sum) num_threads(k)
    {
        nk = n / k;
        nk1 = 0;
        nk2 = nk;
        while (nk2 <= n)
        {
            i = nk1 + 1;
            while (i > nk1 && i <= nk2)
            {
                sum += i;
                i += 1;
            }
            printf("[%d]: Sum = %d\n", omp_get_thread_num(), sum);
            nk1 += nk;
            nk2 += nk;
        }
    }   
    printf("Result: Sum = %d\n", sum);
}

Подскажите, где ошибка, пожалуйста

Добавлено через 58 минут
Если без первого цикла, то 2 потока нормально работают, а больше уже нет (потому что nk1 и nk2 не увеличиваются)

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
#include <omp.h>
#include <stdio.h>
 
void main()
{
    int n, i, k, nk, nk1, nk2, sum(0);
    printf("Enter an integer N: ");
    scanf_s("%d", &n);
    printf("Enter an integer number of threads k: ");
    scanf_s("%d", &k);
    nk = n / k;
    nk1 = 0;
    nk2 = nk;
    i = nk1 + 1;
 
#pragma omp parallel reduction(+:sum) num_threads(k)
    {
        
            while (i > nk1 && i <= nk2)
            {
                sum += i;
                i += 1;
            }
            printf("[%d]: Sum = %d\n", omp_get_thread_num(), sum);
            nk1 += nk;
            nk2 += nk;
    }
    printf("Result: Sum = %d\n", sum);
}

Добавлено через 20 минут
А так работает преимущественно 1 нить

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
#include <omp.h>
#include <stdio.h>
 
void main()
{
    int n, i, k, nk, nk1, nk2, sum(0);
    printf("Enter an integer N: ");
    scanf_s("%d", &n);
    printf("Enter an integer number of threads k: ");
    scanf_s("%d", &k);
    nk = n / k;
    nk1 = 0;
    nk2 = nk;
    i = nk1 + 1;
 
#pragma omp parallel reduction(+:sum) num_threads(k)
    {
        
        for (nk2; nk2 <= n; nk2++)
            for (nk1; nk1 <= (nk2 - nk); nk1++)
            {
                for (i; (i > nk1 && i <= nk2); i++)
                {
                    sum += i;
                }
                printf("[%d]: Sum = %d\n", omp_get_thread_num(), sum);
            }
    }
    printf("Result: Sum = %d\n", sum);
}

Добавлено через 35 минут
Смог сделать через директиву 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
26
#include <omp.h>
#include <stdio.h>
 
void main()
{
    int n, i, k, nk, nk1, nk2, sum(0);
    printf("Enter an integer N: ");
    scanf_s("%d", &n);
    printf("Enter an integer number of threads k: ");
    scanf_s("%d", &k);
    nk = n / k;
    nk1 = 0;
    nk2 = nk;
    i = nk1 + 1;
#pragma omp parallel reduction(+:sum) num_threads(k)
    {
 
 
# pragma omp for
        for (int i = 0; i <= n; ++i)
            sum += i;
        printf("[%d]: Sum = %d\n", omp_get_thread_num(), sum);
    }
    
    printf("Result: Sum = %d\n", sum);
}

@Eddy_Em · 03.12.2021, 19:58

Ну там же есть критические секции. Вот, например, как можно вычислять минимум-максимум:

C
1
2
3
4
5
6
7
8
9
10
11
12
13
14
    #pragma omp parallel shared(min, max)
    {
        float min_p = min, max_p = min;
        #pragma omp for nowait
        for(int i = 0; i < wh; ++i){
            if(f[i] < min_p) min_p = f[i];
            else if(f[i] > max_p) max_p = f[i];
        }
        #pragma omp critical
        {
            if(min > min_p) min = min_p;
            if(max < max_p) max = max_p;
        }
    }

@AlexVRud · 03.12.2021, 22:10

Первое задание:

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
void sum_1(int n) {
    // Итоговая переменная суммы
    int sum = 0;
 
    // Параллельная секция OpenMP
    // Редукция по переменной sum
    // 2 потока
    #pragma omp parallel reduction(+:sum) num_threads(2)
    {
        int a, b;
 
        // Номер потока
        int t_n = omp_get_thread_num();
 
        // Условие для распределения задания
        if (t_n == 0) {
            a = 1;
            b = n / 2;
        } else {
            a = n / 2 + 1;
            b = n;
        }
 
        for(int i = a; i <= b; i++) {
            sum += i;
        }
 
        printf("[%d] sum = %d\n", t_n, sum);
    }
 
    printf("sum = %d\n", sum);
}

Новые блоги и статьи Все статьи Все блоги /
Учёным и волонтёрам проекта «Einstein@home» удалось обнаружить четыре гамма-лучевых пульсара в джете Млечного Пути Programma_Boinc 01.01.2026 Учёным и волонтёрам проекта «Einstein@home» удалось обнаружить четыре гамма-лучевых пульсара в джете Млечного Пути Сочетание глобально распределённой вычислительной мощности и инновационных. . .	Советы по крайней бережливости. Внимание, это ОЧЕНЬ длинный пост. Programma_Boinc 28.12.2025 Советы по крайней бережливости. Внимание, это ОЧЕНЬ длинный пост. Налог на собак: https:/ / ********/ gallery/ V06K53e Финансовый отчет в Excel: https:/ / ********/ gallery/ bKBkQFf Пост отсюда. . .	Кто-нибудь знает, где можно бесплатно получить настольный компьютер или ноутбук? США. Programma_Boinc 26.12.2025 Нашел на реддите интересную статью под названием Anyone know where to get a free Desktop or Laptop? Ниже её машинный перевод. После долгих разбирательств я наконец-то вернула себе. . .	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/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .