1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
/* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
#include "base/threadpool.hpp"
#include <boost/thread/locks.hpp>
using namespace icinga;
ThreadPool::ThreadPool() : m_Pending(0)
{
Start();
}
ThreadPool::~ThreadPool()
{
Stop();
}
void ThreadPool::Start()
{
boost::unique_lock<decltype(m_Mutex)> lock (m_Mutex);
if (!m_Pool) {
InitializePool();
}
}
void ThreadPool::InitializePool()
{
m_Pool = decltype(m_Pool)(new boost::asio::thread_pool(Configuration::Concurrency * 2u));
}
void ThreadPool::Stop()
{
boost::unique_lock<decltype(m_Mutex)> lock (m_Mutex);
if (m_Pool) {
m_Pool->join();
m_Pool = nullptr;
}
}
void ThreadPool::Restart()
{
boost::unique_lock<decltype(m_Mutex)> lock (m_Mutex);
if (m_Pool) {
m_Pool->join();
}
InitializePool();
}
|
