Конструктор потоков C++, используя новый (объект), создает утечки памяти

Question

У меня есть программа, которая имеет класс A, который я хочу запустить в потоке. На самом деле, это то, что A является рабочим, и у меня будет некоторое количество из них, которые работают, которые я хочу отслеживать. Моя проблема в том, что мой текущий способ сделать это вызывает утечку памяти, когда я проверяю ее с помощью valgrind.

#include <iostream> 
#include <thread> 
#include <vector> 

class A { 
    public: 
     double foobar; 

     A() : foobar(0) { }; 
     A(double newfoo) : foobar(newfoo) { }; 
     void runA(double asap) { 
      foobar = asap; 
      std::cout << "foobar is now index: " << foobar << std::endl; 
     } 
}; 

int main() { 
    std::vector<std::thread> aThreads; 
    for(int i = 0; i < 10; i++) { 
     aThreads.push_back(std::thread(&A::runA, new A(1), i)); 
    } 

    for(auto& t : aThreads) { 
     t.join(); 
    } 

    return 0; 
} 

Так что я знаю, что эта проблема является new A(100) вызов, и я действительно не знаю, как справиться с этим. Моя фактическая программа намного больше, и поэтому утечка намного больше памяти, поэтому мне интересно, что я могу здесь сделать. Я попытался создать объект в цикле for, а затем с помощью std::move() попытаться передать указанный объект в поток, но это тоже не получилось. Я знаю, что мне нужно передать адрес памяти, и я знаю, что я хочу, чтобы отдельные объекты были разделены, поскольку они будут выполнять разные задачи.

Как вы решаете проблему утечки памяти в случае, когда вам нужно создать кучу объектов для запуска в своих отдельных потоках?

Answer 1

Вы можете сохранить все указатели на выделенные объекты (например, в векторе), а затем удалить их после ваших потоков соединений.

Answer 2

Сделайте A вызываемым напрямую, затем передайте его по значению.

#include <iostream> 
#include <thread> 
#include <vector> 

class A { 
    public: 
     double foobar; 

     A() : foobar(0) { }; 
     A(double newfoo) : foobar(newfoo) { }; 
     void operator()(double asap) { 
      foobar = asap; 
      std::cout << "foobar is now index: " << foobar << std::endl; 
     } 
}; 

int main() { 
    std::vector<std::thread> aThreads; 
    for(int i = 0; i < 10; i++) { 
     aThreads.push_back(std::thread(A(1), i)); 
    } 

    for(auto& t : aThreads) { 
     t.join(); 
    } 

    return 0; 
}