线程管理内存泄漏
我在我的C ++应用程序中使用reactor模式。 我使用线程向量std::vector <boost::thread> tvec {1000}; 和一个事件队列boost::lockfree::queue <int> events {1000}; 处理事件。
我的事件调度程序看起来像这样：
void my_class::event_dispatcher (void)
{
INFO << "started";
int event_element = 0;
try
{
while (true)
{
// 1. wait for an event
for (;;)
{
if (events.pop (event_element)) break; // returns true if the queue is not empty
boost::this_thread::sleep (boost::posix_time::milliseconds (250));
}
// 2. handle event
switch (event_element)
{
// 1-20 ...
case 21:
{
tvec.at(21).interrupt();
tvec.at(21) = boost::thread (boost::bind(&my_class::write_units_court_a, this));
break;
}
// 21-999...
default:
{
WARNING << "INVALID EVENT = " << event_element;
break;
}
}
}
}
catch (const std::exception &e)
{
ERROR << "e.what() = " << e.what();
return;
}
INFO << "ended";
return;
}
我的问题是，当我运行pmap -x PROGRAM_PID它显示了几十行这些行：
00007f4063fd9000 8192 12 12 rw--- [ anon ]
00007f4063fd9000 0 0 0 rw--- [ anon ]
00007f40647d9000 4 0 0 ----- [ anon ]
00007f40647d9000 0 0 0 ----- [ anon ]
00007f40647da000 8192 16 16 rw--- [ anon ]
00007f40647da000 0 0 0 rw--- [ anon ]
00007f4064fda000 4 0 0 ----- [ anon ]
00007f4064fda000 0 0 0 ----- [ anon ]
00007f4064fdb000 8192 12 12 rw--- [ anon ]
00007f4064fdb000 0 0 0 rw--- [ anon ]
00007f40657db000 4 0 0 ----- [ anon ]
00007f40657db000 0 0 0 ----- [ anon ]
我认为这是我的事件调度程序在程序运行时创建并中断多个线程的内存泄漏。 我在这些线程中使用boost记录并正确捕获线程中的中断; 例：
void my_class::write_units_court_a (void)
{
INFO << "started";
try
{
// working code here ...
}
catch (const std::exception &e)
{
ERROR << "e.what() = " << e.what();
return;
}
catch (boost::thread_interrupted)
{
INFO << "interrupted";
return;
}
INFO << "ended";
return;
}
什么导致这个看似线程内存泄漏？ Valgrind显示丢失的内存，我可以看到程序使用更多的内存，因为它开始和结束线程。
我现在使用boost::shared_ptr <boost::thread> thr_ev_21; 和
if (thr_ev_21.get()) thr_ev_21->interrupt();
thr_ev_21.reset(new boost::thread (boost::bind(&porter::write_units_court_a, this)));
现在我的内存使用高峰而不是不断增长。 线程对象不得在第二遍时通过此行销毁：
tvec.at(21) = boost::thread (boost::bind(&my_class::write_units_court_a, this));