Многопоточность в 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);
}

Новые блоги и статьи Все статьи Все блоги /
Модульный подход на примере F# DevAlt 06.03.2026 В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .	Управление камерой с помощью скрипта OrbitControls.js на Three.js: Вращение, зум и панорамирование 8Observer8 05.03.2026 Содержание блога Финальная демка в браузере работает на Desktop и мобильных браузерах. Итоговый код: orbit-controls-threejs-js. zip. Сканируйте QR-код на мобильном. Вращайте камеру одним пальцем,. . .	SDL3 для Web (WebAssembly): Синхронизация спрайтов SDL3 и тел Box2D 8Observer8 04.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-sync-physics-sprites-sdl3-c. zip На первой гифке отладочные линии отключены, а на второй включены:. . .	SDL3 для Web (WebAssembly): Идентификация объектов на Box2D v3 - использование userData и событий коллизий 8Observer8 02.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-collision-events-sdl3-c. zip Сканируйте QR-код на мобильном и вы увидите, что появится джойстик для управления главным героем. . . .
Реалии Hrethgir 01.03.2026 Нет, я не закончил до сих пор симулятор. Эта задача сложнее. Не получилось уйти в плавсостав, но оно и к лучшему, возможно. Точнее получалось - но сварщиком в палубную команду, а это значит, в моём. . .	Ритм жизни kumehtar 27.02.2026 Иногда приходится жить в ритме, где дел становится всё больше, а вовлечения в происходящее — всё меньше. Плотный график не даёт вниманию закрепиться ни на одном событии. Утро начинается с быстрых,. . .	SDL3 для Web (WebAssembly): Сборка библиотек: SDL3, Box2D, FreeType, SDL3_ttf, SDL3_mixer и SDL3_image из исходников с помощью CMake и Emscripten 8Observer8 27.02.2026 Недавно вышла версия 3. 4. 2 библиотеки SDL3. На странице официальной релиза доступны исходники, готовые DLL (для x86, x64, arm64), а также библиотеки для разработки под Android, MinGW и Visual Studio. . . .	SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами 8Observer8 20.02.2026 Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .