diff --git a/src/thread/pithread.cpp b/src/thread/pithread.cpp index a5debcda..44a5eaa4 100755 --- a/src/thread/pithread.cpp +++ b/src/thread/pithread.cpp @@ -127,7 +127,7 @@ bool PIThread::start(int timer_delay) { # endif pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); int ret = pthread_create(&thread, &attr, thread_function, this); - piCout << "pthread_create" << thread; + //piCout << "pthread_create" << thread; pthread_attr_destroy(&attr); if (ret == 0) { #else @@ -158,7 +158,7 @@ bool PIThread::startOnce() { # endif pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); int ret = pthread_create(&thread, &attr, thread_function_once, this); - piCout << "pthread_create" << thread; + //piCout << "pthread_create" << thread; pthread_attr_destroy(&attr); if (ret == 0) { #else @@ -181,7 +181,7 @@ bool PIThread::startOnce() { void PIThread::terminate() { if (thread == 0) return; terminating = running_ = false; - piCout << "terminate" << thread; + //piCout << "terminate" << thread; #ifndef WINDOWS # ifdef ANDROID pthread_kill(thread, SIGTERM); @@ -239,7 +239,7 @@ __THREAD_FUNC__ PIThread::thread_function(void * t) { if (ct.lockRun) ct.mutex_.unlock(); ct.terminating = ct.running_ = false; //cout << "thread " << t << " exiting ... " << endl; - piCout << "pthread_exit" << ct.thread; + //piCout << "pthread_exit" << ct.thread; #ifndef WINDOWS pthread_detach(ct.thread); ct.thread = 0; @@ -275,7 +275,7 @@ __THREAD_FUNC__ PIThread::thread_function_once(void * t) { ct.end(); ct.terminating = ct.running_ = false; //cout << "thread " << t << " exiting ... " << endl; - piCout << "pthread_exit" << ct.thread; + //piCout << "pthread_exit" << ct.thread; #ifndef WINDOWS pthread_detach(ct.thread); ct.thread = 0; @@ -322,8 +322,8 @@ int PIThread::priority2System(PIThread::Priority p) { void PIThread::setPriority(PIThread::Priority prior) { priority_ = prior; #ifndef WINDOWS - if (!running_ && (thread != 0)) return; - piCout << "setPriority" << thread; + if (!running_ || (thread == 0)) return; + //piCout << "setPriority" << thread; policy_ = 0; memset(&sparam, 0, sizeof(sparam)); pthread_getschedparam(thread, &policy_, &sparam); @@ -336,7 +336,7 @@ void PIThread::setPriority(PIThread::Priority prior) { = priority2System(priority_); pthread_setschedparam(thread, policy_, &sparam); #else - if (!running_ && (thread != 0)) return; + if (!running_ || (thread == 0)) return; SetThreadPriority(thread, priority2System(priority_)); #endif }