0

Пытаюсь задать функцию в отдельном потоке. Но почему-то не выходит вот код :

#include <stdio.h>
#include <omp.h>

void send_func(int s_v); //отправка
void reception_func(int s_v); // приём

int main()
{
        omp_set_num_threads(1);
        // фукция отправки
        send_func(10);

         omp_set_num_threads(1);
        // функция приёма
        reception_func(10);

}

// omp_set_num_threads(1); // так вообще выдаёт ошибку 
void send_func(int s_v)
{
    omp_set_num_threads(1);
    for(int i=0;i<10;i++){printf("Thread %d | 1 s_v = %d \n",omp_get_thread_num(),s_v);}
}

// omp_set_num_threads(1); // так вообще выдаёт ошибку 
void reception_func(int s_v)
{
    omp_set_num_threads(1);
    for(int i=0;i<10;i++){printf("Thread %d | 2 s_v = %d \n",omp_get_thread_num(), s_v);}
}

Увы всё исполняет в одном потоке ;_;

1 ответ 1

1
#include <stdio.h>
#include <omp.h>

void send_func(int s_v); //отправка
void reception_func(int s_v); // приём

int main()
{

#pragma omp parallel sections
    // тут запукстить два потока  ПО одному !!!
    {
#pragma omp section
        {
//        omp_set_num_threads(1);
        // фукция отправки
        send_func(10);
        }
#pragma omp section
        {
//        omp_set_num_threads(1);
        // функция приёма
        reception_func(10);
        }
    }
}

void send_func(int s_v)
{
    for(int i=0;i<10;i++){printf("Thread %d | 1 s_v = %d \n",omp_get_thread_num(),s_v);}
}

void reception_func(int s_v)
{
    for(int i=0;i<10;i++){printf("Thread %d | 2 s_v = %d \n",omp_get_thread_num(), s_v);}
}

Вот вывод программы:

Thread 1 | 1 s_v = 10 
Thread 1 | 1 s_v = 10 
Thread 1 | 1 s_v = 10 
Thread 1 | 1 s_v = 10 
Thread 1 | 1 s_v = 10 
Thread 1 | 1 s_v = 10 
Thread 1 | 1 s_v = 10 
Thread 1 | 1 s_v = 10 
Thread 1 | 1 s_v = 10 
Thread 1 | 1 s_v = 10 
Thread 0 | 2 s_v = 10 
Thread 0 | 2 s_v = 10 
Thread 0 | 2 s_v = 10 
Thread 0 | 2 s_v = 10 
Thread 0 | 2 s_v = 10 
Thread 0 | 2 s_v = 10 
Thread 0 | 2 s_v = 10 
Thread 0 | 2 s_v = 10 
Thread 0 | 2 s_v = 10 
Thread 0 | 2 s_v = 10 
7
  • Все гуд, но omp_set_num_threads точно не нужен), лучше выше максимум потоков обозначить)
    – Oh-Ben-Ben
    6 дек 2019 в 12:51
  • через omp_set_num_threads(omp_get_max_threads());
    – Oh-Ben-Ben
    6 дек 2019 в 12:59
  • @Andrey исправил, так же почему-то гонит на вызов /home/comp/Qt_project/untopenmp/main.c:25: ошибка: void value not ignored as it ought to be int n = omp_set_num_threads(omp_get_max_threads()); ^~~~~~~~~~~~~~~~~~~
    – timob256
    6 дек 2019 в 13:57
  • Эм... написано же воид. Это функция не возвращает значение, что Вы хотите записать в n? Это просто сеттер
    – Oh-Ben-Ben
    6 дек 2019 в 13:59
  • 1

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими пользовательским соглашением, политикой конфиденциальности и политикой о куки

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.