OpenMP, не создаются потоки

#include <omp.h>
#include <iostream>
#include <windows.h> // Для Sleep()
#include <string>
 
#define MAX 5 // размер массива для хранения информации от Производителей
 
using namespace std;
 
void producer(int prod){
    int n = 0;
    omp_set_dynamic(0);
#pragma omp parallel num_threads (prod) private(n)
    {
        int a = 0;
        a+=1;
        while (true){
            cout << "Сгенерировано сообщение номер "<< n << " от Производителя номер " << omp_get_thread_num() << endl;
            n+=1;
            Sleep(1000);
        }
    }
}
 
void consumer(int cons){
    omp_set_dynamic(0);
#pragma omp parallel num_threads (cons)
    {
        while (true){
            cout << "Получено сообщение из массива данных Потребителем номер " << omp_get_thread_num() << endl;
            Sleep(2000);
        }
    }
}
 
int main() {
    setlocale(LC_ALL,"Russian");
    int prod,cons;
 
    cout << "Введите количество Производителей:";
    cin >> prod;
    cout << "Введите количество Потребителей:";
    cin >> cons;
    cout << "              Моделирование началось:" << endl;
    
    #pragma omp parallel sections num_threads(2) 
        {
                #pragma omp section
                    {
                        producer(prod);
                    }
                #pragma omp section
                    {
                        consumer(cons);
                    }
        }
 
    getchar();
}

#include <omp.h>
#include <iostream>
#include <windows.h> // Для Sleep()
#include <string>
 
#define MAX 5 // Размер массива для хранения поступающей информации от Производителей
int flag = 0; // Текущая позиция для считывания/записи данных
int MESSAGE = 0; // Целые числа, передаваемые от Производителей Потребителям
omp_lock_t lock; // Замок для синхронизации доступа к общим данным
 
using namespace std;
 
void producer(int *myArray){
        while (true){
            //omp_set_lock(&lock);
            // пробую неблокирующий захват замка
            while (!omp_test_lock(&lock));
            if (flag <= MAX -1) { 
                myArray[flag*MAX+0] = MESSAGE;
                myArray[flag*MAX+1] = omp_get_thread_num();
                cout << "Записано сообщение номер "<< MESSAGE << " от Производителя номер " << omp_get_thread_num() << endl;
                flag+=1;
                MESSAGE+=1; // Генерируется сообщение
            }
            omp_unset_lock(&lock);
        }
}
 
void consumer(int *myArray){
        while (true){
            //omp_set_lock(&lock);
            // пробую неблокирующий захват замка
            while (!omp_test_lock(&lock));
            if (flag > 0){ // Только когда уже есть данные в массиве
                cout << "Получено сообщение номер "<<myArray[(flag-1)*MAX+0]<< " из массива данных от Производителя "<<myArray[(flag-1)*MAX+1]<< " Потребителем номер " << omp_get_thread_num() << endl;
                myArray[(flag-1)*MAX+0] = 0;
                myArray[(flag-1)*MAX+1] = 0;
                flag -= 1 ;
            }
            omp_unset_lock(&lock);          
        }
}
 
int main() {
    setlocale(LC_ALL,"Russian");
    int prod,cons;
    int *myArray = new int[MAX * 2]; // Для хранения номера сообщения и номера потока-Производителя
    
    for (int i = 0; i < MAX; i++)   // Обнуляем массив
        for (int j = 0; j < 2; j++)
            myArray[i*2 + j] = 0;
    
    cout << "        Программа для моделирования задачи" << endl;
    cout << "            Производители-Потребители."<<endl;
    cout << "=====================================================" <<endl <<endl;
    cout << "Введите количество Производителей:";
    cin >> prod;
    cout << "Введите количество Потребителей:";
    cin >> cons;
 
    cout << "=====================================================" <<endl <<endl;
    cout << "              Моделирование началось:" << endl;
 
    omp_set_dynamic(0); // Запрещаем системе динамически менять количество нитей
    omp_set_nested(1); // Разрешаем вложенный параллелизм
    omp_init_lock(&lock); // Инициализация замка
    #pragma omp parallel sections num_threads(2) 
        {
                #pragma omp section
                    {
                        #pragma omp parallel num_threads (prod) shared (flag,MESSAGE,myArray)
                        producer(myArray);
                    }
                #pragma omp section
                    {
                        #pragma omp parallel num_threads (cons) shared (flag,MESSAGE,myArray)
                        consumer(myArray);
                    }
        }
        omp_destroy_lock(&lock);
    getchar();
}