Утечка памяти при использовании OpenMP

В приведенном ниже тестовом примере не хватает памяти на 32-битных машинах (бросает std :: bad_alloc) в цикле после сообщения «post MT section», когда используется OpenMP, однако, если #pragmas для OpenMP закомментированы, код проходит до завершения нормально, поэтому кажется, что когда память распределяется в параллельных потоках, она не освобождается правильно, и поэтому у нас заканчивается память.

Вопрос в том, есть ли там что-то не так с кодом выделения и удаления памяти ниже, или это ошибка в gcc v4.2.2 или OpenMP? Я также попробовал gcc v4.3 и получил ту же ошибку.

int main(int argc, char** argv)
{
    std::cout << "start " << std::endl;

    {
            std::vector<std::vector<int*> > nts(100);
            #pragma omp parallel
            {
                    #pragma omp for
                    for(int begin = 0; begin < int(nts.size()); ++begin) {
                            for(int i = 0; i < 1000000; ++i) {
                                    nts[begin].push_back(new int(5));
                            }
                    }
            }

    std::cout << "  pre delete " << std::endl;
            for(int begin = 0; begin < int(nts.size()); ++begin) {
                    for(int j = 0; j < nts[begin].size(); ++j) {
                            delete nts[begin][j];
                    }
            }
    }
    std::cout << "post MT section" << std::endl;
    {
            std::vector<std::vector<int*> > nts(100);
            int begin, i;
            try {
              for(begin = 0; begin < int(nts.size()); ++begin) {
                    for(i = 0; i < 2000000; ++i) {
                            nts[begin].push_back(new int(5));
                    }
              }
            } catch (std::bad_alloc &e) {
                    std::cout << e.what() << std::endl;
                    std::cout << "begin: " << begin << " i: " << i << std::endl;
                    throw;
            }
            std::cout << "pre delete 1" << std::endl;

            for(int begin = 0; begin < int(nts.size()); ++begin) {
                    for(int j = 0; j < nts[begin].size(); ++j) {
                            delete nts[begin][j];
                    }
            }
    }

    std::cout << "end of prog" << std::endl;

    char c;
    std::cin >> c;

    return 0;
}
5
задан WilliamKF 3 December 2010 в 12:07
поделиться