github
/
teleport
mirror of https://github.com/tp4a/teleport
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

.temp.

pull/236/head
Apex Liu 2019-12-16 19:56:57 +08:00
parent d960f889ab
commit 6279ec73f3
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
common/libex/src/ex_thread.cpp
View File

@ -20,7 +20,7 @@ void *ExThreadBase::_thread_func(void *pParam)
_this->m_is_running = false; _this->m_is_running = false;
_this->m_handle = 0; _this->m_handle = 0;
EXLOGV(" # thread [%s] exit.\n", _this->m_thread_name.c_str()); EXLOGV("[thread] - `%s` exit.\n", _this->m_thread_name.c_str());
_this->_on_stopped(); _this->_on_stopped();
return 0; return 0;
} }
@ -34,13 +34,13 @@ ExThreadBase::ExThreadBase(const char *thread_name) :
ExThreadBase::~ExThreadBase() { ExThreadBase::~ExThreadBase() {
if(m_is_running) { if(m_is_running) {
EXLOGE(" # thread [%s] not stop before destroy.\n", m_thread_name.c_str()); EXLOGE("[thread] `%s` not stop before destroy.\n", m_thread_name.c_str());
} }
} }
bool ExThreadBase::start(void) { bool ExThreadBase::start(void) {
m_need_stop = false; m_need_stop = false;
EXLOGV(" . thread [%s] starting.\n", m_thread_name.c_str()); EXLOGV("[thread] + `%s` starting.\n", m_thread_name.c_str());
#ifdef WIN32 #ifdef WIN32
HANDLE h = (HANDLE)_beginthreadex(NULL, 0, _thread_func, (void*)this, 0, NULL); HANDLE h = (HANDLE)_beginthreadex(NULL, 0, _thread_func, (void*)this, 0, NULL);
@ -64,15 +64,15 @@ bool ExThreadBase::start(void) {
bool ExThreadBase::stop(void) { bool ExThreadBase::stop(void) {
if (m_handle == 0) { if (m_handle == 0) {
EXLOGW("[thread] thread [%s] already stopped.\n", m_thread_name.c_str()); EXLOGW("[thread] `%s` already stopped before stop() call.\n", m_thread_name.c_str());
return true; return true;
} }
EXLOGV("[thread] try to stop thread [%s].\n", m_thread_name.c_str()); EXLOGV("[thread] - try to stop `%s.\n", m_thread_name.c_str());
m_need_stop = true; m_need_stop = true;
_on_stop(); _on_stop();
EXLOGV("[thread] wait thread [%s] exit, thread-handle=0x%08x.\n", m_thread_name.c_str(), m_handle); EXLOGV("[thread] - wait `%s` exit, thread-handle=0x%08x.\n", m_thread_name.c_str(), m_handle);
#ifdef EX_OS_WIN32 #ifdef EX_OS_WIN32
if (m_handle) { if (m_handle) {
@ -107,7 +107,7 @@ ExThreadManager::ExThreadManager() {}
ExThreadManager::~ExThreadManager() { ExThreadManager::~ExThreadManager() {
if (!m_threads.empty()) { if (!m_threads.empty()) {
EXLOGE("when destroy thread manager, there are %d thread not exit.\n", m_threads.size()); EXLOGE("[thread] when destroy thread manager, there are %d thread not exit.\n", m_threads.size());
stop_all(); stop_all();
} }
} }
@ -128,7 +128,7 @@ void ExThreadManager::add(ExThreadBase *tb) {
ex_threads::iterator it = m_threads.begin(); ex_threads::iterator it = m_threads.begin();
for (; it != m_threads.end(); ++it) { for (; it != m_threads.end(); ++it) {
if ((*it) == tb) { if ((*it) == tb) {
EXLOGE("when add thread to manager, it already exist.\n"); EXLOGE("[thread] when add thread to manager, it already exist.\n");
return; return;
} }
} }
@ -146,7 +146,7 @@ void ExThreadManager::remove(ExThreadBase *tb) {
return; return;
} }
} }
EXLOGE("thread not hold by thread-manager while remove it.\n"); EXLOGE("[thread] thread not hold by thread-manager while remove it.\n");
} }
//========================================================= //=========================================================