mirror of https://github.com/Icinga/icinga2.git
commit
c17b3ee9ae
|
@ -40,8 +40,8 @@ ThreadPool::ThreadPool(void)
|
||||||
for (int i = 0; i < 2; i++)
|
for (int i = 0; i < 2; i++)
|
||||||
SpawnWorker();
|
SpawnWorker();
|
||||||
|
|
||||||
m_ManagerThread = boost::thread(boost::bind(&ThreadPool::ManagerThreadProc, this));
|
m_Threads.create_thread(boost::bind(&ThreadPool::ManagerThreadProc, this));
|
||||||
m_StatsThread = boost::thread(boost::bind(&ThreadPool::StatsThreadProc, this));
|
m_Threads.create_thread(boost::bind(&ThreadPool::StatsThreadProc, this));
|
||||||
}
|
}
|
||||||
|
|
||||||
ThreadPool::~ThreadPool(void)
|
ThreadPool::~ThreadPool(void)
|
||||||
|
@ -63,6 +63,7 @@ void ThreadPool::Stop(void)
|
||||||
*/
|
*/
|
||||||
void ThreadPool::Join(void)
|
void ThreadPool::Join(void)
|
||||||
{
|
{
|
||||||
|
{
|
||||||
boost::mutex::scoped_lock lock(m_Mutex);
|
boost::mutex::scoped_lock lock(m_Mutex);
|
||||||
|
|
||||||
while (!m_Stopped || !m_WorkItems.empty()) {
|
while (!m_Stopped || !m_WorkItems.empty()) {
|
||||||
|
@ -70,17 +71,9 @@ void ThreadPool::Join(void)
|
||||||
Utility::Sleep(0.5);
|
Utility::Sleep(0.5);
|
||||||
lock.lock();
|
lock.lock();
|
||||||
}
|
}
|
||||||
|
|
||||||
for (size_t i = 0; i < sizeof(m_Threads) / sizeof(m_Threads[0]); i++) {
|
|
||||||
lock.unlock();
|
|
||||||
m_Threads[i].Thread.join();
|
|
||||||
lock.lock();
|
|
||||||
|
|
||||||
m_Threads[i].State = ThreadDead;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
m_ManagerThread.join();
|
m_Threads.join_all();
|
||||||
m_StatsThread.join();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -100,10 +93,10 @@ void ThreadPool::QueueThreadProc(int tid)
|
||||||
|
|
||||||
UpdateThreadUtilization(tid, ThreadIdle);
|
UpdateThreadUtilization(tid, ThreadIdle);
|
||||||
|
|
||||||
while (m_WorkItems.empty() && !m_Stopped && !m_Threads[tid].Zombie)
|
while (m_WorkItems.empty() && !m_Stopped && !m_ThreadStats[tid].Zombie)
|
||||||
m_WorkCV.wait(lock);
|
m_WorkCV.wait(lock);
|
||||||
|
|
||||||
if (m_Threads[tid].Zombie)
|
if (m_ThreadStats[tid].Zombie)
|
||||||
break;
|
break;
|
||||||
|
|
||||||
if (m_WorkItems.empty() && m_Stopped)
|
if (m_WorkItems.empty() && m_Stopped)
|
||||||
|
@ -184,7 +177,7 @@ void ThreadPool::QueueThreadProc(int tid)
|
||||||
|
|
||||||
boost::mutex::scoped_lock lock(m_Mutex);
|
boost::mutex::scoped_lock lock(m_Mutex);
|
||||||
UpdateThreadUtilization(tid, ThreadDead);
|
UpdateThreadUtilization(tid, ThreadDead);
|
||||||
m_Threads[tid].Zombie = false;
|
m_ThreadStats[tid].Zombie = false;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -236,10 +229,10 @@ void ThreadPool::ManagerThreadProc(void)
|
||||||
|
|
||||||
alive = 0;
|
alive = 0;
|
||||||
|
|
||||||
for (size_t i = 0; i < sizeof(m_Threads) / sizeof(m_Threads[0]); i++) {
|
for (size_t i = 0; i < sizeof(m_ThreadStats) / sizeof(m_ThreadStats[0]); i++) {
|
||||||
if (m_Threads[i].State != ThreadDead && !m_Threads[i].Zombie) {
|
if (m_ThreadStats[i].State != ThreadDead && !m_ThreadStats[i].Zombie) {
|
||||||
alive++;
|
alive++;
|
||||||
utilization += m_Threads[i].Utilization * 100;
|
utilization += m_ThreadStats[i].Utilization * 100;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -297,14 +290,12 @@ void ThreadPool::ManagerThreadProc(void)
|
||||||
*/
|
*/
|
||||||
void ThreadPool::SpawnWorker(void)
|
void ThreadPool::SpawnWorker(void)
|
||||||
{
|
{
|
||||||
for (size_t i = 0; i < sizeof(m_Threads) / sizeof(m_Threads[0]); i++) {
|
for (size_t i = 0; i < sizeof(m_ThreadStats) / sizeof(m_ThreadStats[0]); i++) {
|
||||||
if (m_Threads[i].State == ThreadDead) {
|
if (m_ThreadStats[i].State == ThreadDead) {
|
||||||
Log(LogDebug, "debug", "Spawning worker thread.");
|
Log(LogDebug, "debug", "Spawning worker thread.");
|
||||||
|
|
||||||
m_Threads[i].State = ThreadIdle;
|
m_ThreadStats[i] = ThreadStats(ThreadIdle);
|
||||||
|
m_Threads.create_thread(boost::bind(&ThreadPool::QueueThreadProc, this, i));
|
||||||
boost::thread thread(boost::bind(&ThreadPool::QueueThreadProc, this, i));
|
|
||||||
m_Threads[i].Thread = boost::move(thread);
|
|
||||||
|
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
@ -316,11 +307,11 @@ void ThreadPool::SpawnWorker(void)
|
||||||
*/
|
*/
|
||||||
void ThreadPool::KillWorker(void)
|
void ThreadPool::KillWorker(void)
|
||||||
{
|
{
|
||||||
for (size_t i = 0; i < sizeof(m_Threads) / sizeof(m_Threads[0]); i++) {
|
for (size_t i = 0; i < sizeof(m_ThreadStats) / sizeof(m_ThreadStats[0]); i++) {
|
||||||
if (m_Threads[i].State == ThreadIdle && !m_Threads[i].Zombie) {
|
if (m_ThreadStats[i].State == ThreadIdle && !m_ThreadStats[i].Zombie) {
|
||||||
Log(LogDebug, "base", "Killing worker thread.");
|
Log(LogDebug, "base", "Killing worker thread.");
|
||||||
|
|
||||||
m_Threads[i].Zombie = true;
|
m_ThreadStats[i].Zombie = true;
|
||||||
m_WorkCV.notify_all();
|
m_WorkCV.notify_all();
|
||||||
|
|
||||||
break;
|
break;
|
||||||
|
@ -343,7 +334,7 @@ void ThreadPool::StatsThreadProc(void)
|
||||||
if (m_Stopped)
|
if (m_Stopped)
|
||||||
break;
|
break;
|
||||||
|
|
||||||
for (size_t i = 0; i < sizeof(m_Threads) / sizeof(m_Threads[0]); i++)
|
for (size_t i = 0; i < sizeof(m_ThreadStats) / sizeof(m_ThreadStats[0]); i++)
|
||||||
UpdateThreadUtilization(i);
|
UpdateThreadUtilization(i);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -355,7 +346,7 @@ void ThreadPool::UpdateThreadUtilization(int tid, ThreadState state)
|
||||||
{
|
{
|
||||||
double utilization;
|
double utilization;
|
||||||
|
|
||||||
switch (m_Threads[tid].State) {
|
switch (m_ThreadStats[tid].State) {
|
||||||
case ThreadDead:
|
case ThreadDead:
|
||||||
return;
|
return;
|
||||||
case ThreadIdle:
|
case ThreadIdle:
|
||||||
|
@ -369,16 +360,16 @@ void ThreadPool::UpdateThreadUtilization(int tid, ThreadState state)
|
||||||
}
|
}
|
||||||
|
|
||||||
double now = Utility::GetTime();
|
double now = Utility::GetTime();
|
||||||
double time = now - m_Threads[tid].LastUpdate;
|
double time = now - m_ThreadStats[tid].LastUpdate;
|
||||||
|
|
||||||
const double avg_time = 5.0;
|
const double avg_time = 5.0;
|
||||||
|
|
||||||
if (time > avg_time)
|
if (time > avg_time)
|
||||||
time = avg_time;
|
time = avg_time;
|
||||||
|
|
||||||
m_Threads[tid].Utilization = (m_Threads[tid].Utilization * (avg_time - time) + utilization * time) / avg_time;
|
m_ThreadStats[tid].Utilization = (m_ThreadStats[tid].Utilization * (avg_time - time) + utilization * time) / avg_time;
|
||||||
m_Threads[tid].LastUpdate = now;
|
m_ThreadStats[tid].LastUpdate = now;
|
||||||
|
|
||||||
if (state != ThreadUnspecified)
|
if (state != ThreadUnspecified)
|
||||||
m_Threads[tid].State = state;
|
m_ThreadStats[tid].State = state;
|
||||||
}
|
}
|
||||||
|
|
|
@ -57,15 +57,14 @@ private:
|
||||||
ThreadBusy
|
ThreadBusy
|
||||||
};
|
};
|
||||||
|
|
||||||
struct WorkerThread
|
struct ThreadStats
|
||||||
{
|
{
|
||||||
boost::thread Thread;
|
|
||||||
ThreadState State;
|
ThreadState State;
|
||||||
bool Zombie;
|
bool Zombie;
|
||||||
double Utilization;
|
double Utilization;
|
||||||
double LastUpdate;
|
double LastUpdate;
|
||||||
|
|
||||||
WorkerThread(ThreadState state = ThreadDead)
|
ThreadStats(ThreadState state = ThreadDead)
|
||||||
: State(state), Zombie(false), Utilization(0), LastUpdate(0)
|
: State(state), Zombie(false), Utilization(0), LastUpdate(0)
|
||||||
{ }
|
{ }
|
||||||
};
|
};
|
||||||
|
@ -73,10 +72,8 @@ private:
|
||||||
int m_ID;
|
int m_ID;
|
||||||
static int m_NextID;
|
static int m_NextID;
|
||||||
|
|
||||||
WorkerThread m_Threads[512];
|
boost::thread_group m_Threads;
|
||||||
|
ThreadStats m_ThreadStats[512];
|
||||||
boost::thread m_ManagerThread;
|
|
||||||
boost::thread m_StatsThread;
|
|
||||||
|
|
||||||
double m_WaitTime;
|
double m_WaitTime;
|
||||||
double m_ServiceTime;
|
double m_ServiceTime;
|
||||||
|
|
|
@ -67,3 +67,4 @@ Value AExpression::Evaluate(const Object::Ptr& thisRef) const
|
||||||
ASSERT(!"Invalid operator.");
|
ASSERT(!"Invalid operator.");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -61,3 +61,4 @@ private:
|
||||||
}
|
}
|
||||||
|
|
||||||
#endif /* AVALUE_H */
|
#endif /* AVALUE_H */
|
||||||
|
|
||||||
|
|
|
@ -54,3 +54,4 @@ ConfigCompilerContext *ConfigCompilerContext::GetInstance(void)
|
||||||
{
|
{
|
||||||
return Singleton<ConfigCompilerContext>::GetInstance();
|
return Singleton<ConfigCompilerContext>::GetInstance();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -24,3 +24,4 @@
|
||||||
#endif /* _WIN32 */
|
#endif /* _WIN32 */
|
||||||
|
|
||||||
#include <boost/test/unit_test.hpp>
|
#include <boost/test/unit_test.hpp>
|
||||||
|
|
||||||
|
|
|
@ -148,3 +148,4 @@ private:
|
||||||
}
|
}
|
||||||
|
|
||||||
#endif /* CLASSCOMPILER_H */
|
#endif /* CLASSCOMPILER_H */
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue