atria-soft/ethread
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

[DEBUG] correct the stop of the pool ...

Browse Source
This commit is contained in:
Edouard DUPIN 2016-12-08 00:01:11 +01:00
parent 2c17a43c99
commit bb4424342e
2 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
ethread/Pool.cpp
View File

@ -99,6 +99,7 @@ void ethread::Pool::stop() {
continue; continue;
} }
(*it)->stop(); (*it)->stop();
++it;
} }
} }

18
ethread/PoolExecutor.cpp
View File

@ -21,7 +21,7 @@ ethread::PoolExecutor::PoolExecutor(ethread::Pool& _pool):
} }
void ethread::PoolExecutor::threadCallback() { void ethread::PoolExecutor::threadCallback() {
ETHREAD_DEBUG("RUN: thread in Pool [START]"); ETHREAD_INFO("[" << m_uniqueId << "] RUN: thread in Pool [START]");
ethread::setName("pool " + etk::to_string(m_uniqueId)); ethread::setName("pool " + etk::to_string(m_uniqueId));
// get datas: // get datas:
while (m_running == true) { while (m_running == true) {
@ -37,11 +37,11 @@ void ethread::PoolExecutor::threadCallback() {
m_action.reset(); m_action.reset();
} }
m_running = false; m_running = false;
ETHREAD_DEBUG("RUN: thread in Pool [STOP]"); ETHREAD_INFO("[" << m_uniqueId << "] RUN: thread in Pool [STOP]");
} }
void ethread::PoolExecutor::start() { void ethread::PoolExecutor::start() {
ETHREAD_DEBUG("START: thread in Pool [START]"); ETHREAD_INFO("START: thread in Pool [START]");
m_running = true; m_running = true;
m_thread = ememory::makeShared<std::thread>([&](void *){ this->threadCallback();}, nullptr); m_thread = ememory::makeShared<std::thread>([&](void *){ this->threadCallback();}, nullptr);
if (m_thread == nullptr) { if (m_thread == nullptr) {
@ -50,23 +50,23 @@ void ethread::PoolExecutor::start() {
return; return;
} }
//ethread::setPriority(*m_receiveThread, -6); //ethread::setPriority(*m_receiveThread, -6);
ETHREAD_DEBUG("START: thread in Pool [STOP]"); ETHREAD_INFO("START: thread in Pool [STOP]");
} }
void ethread::PoolExecutor::stop() { void ethread::PoolExecutor::stop() {
ETHREAD_DEBUG("STOP: thread in Pool [START]"); ETHREAD_INFO("[" << m_uniqueId << "] STOP: thread in Pool [START]");
m_running = false; m_running = false;
ETHREAD_DEBUG("STOP: thread in Pool [STOP]"); ETHREAD_INFO("[" << m_uniqueId << "] STOP: thread in Pool [STOP]");
} }
void ethread::PoolExecutor::join() { void ethread::PoolExecutor::join() {
ETHREAD_DEBUG("JOIN: thread in Pool [START]"); ETHREAD_INFO("[" << m_uniqueId << "] JOIN: thread in Pool [START]");
if (m_thread != nullptr) { if (m_thread != nullptr) {
ETHREAD_DEBUG("JOIN: waiting ..."); ETHREAD_INFO("[" << m_uniqueId << "] JOIN: waiting ...");
m_thread->join(); m_thread->join();
m_thread.reset(); m_thread.reset();
} }
ETHREAD_DEBUG("JOIN: thread in Pool [STOP]"); ETHREAD_INFO("[" << m_uniqueId << "] JOIN: thread in Pool [STOP]");
} }