gradido/login_server/src/cpp/tasks/Thread.cpp

//#include "lib/Thread.h"
//#include "UniversumLib.h"
#include "Thread.h"
#include "../lib/NotificationList.h"

namespace UniLib {
    namespace lib {

        Thread::Thread(const char* threadName/* = NULL*/, bool createInConstructor/* = true*/)
            : mPocoThread(nullptr), exitCalled(false)
        {
			if (createInConstructor) init(threadName);
        } 

		int Thread::init(const char* threadName)
		{
			//semaphore.wait();
			mPocoThread = new Poco::Thread(threadName);
			mPocoThread->start(*this);
			return 0;
		}

        Thread::~Thread()
        {
			//printf("[Thread::~Thread]\n");
            if(mPocoThread)
            {
                //Post Exit to Thread
                exitCalled = true;
				//printf("[Thread::~Thread] before semaphore wait\n");
				//semaphore.wait();
				//printf("[Thread::~Thread] after semaphore wait, before condSignal\n");
                condSignal();
				//printf("[Thread::~Thread] after condSignal, before thread join\n");
                //SDL_Delay(500);
				mPocoThread->join();
				//printf("[Thread::~Thread] after thread join\n");
                //SDL_WaitThread(thread, NULL);
                //LOG_WARNING_SDL();
				delete mPocoThread;

				mPocoThread = nullptr;
            }
        }

        int Thread::condSignal()
        {
			condition.signal();
            /*if(SDL_CondSignal(condition)== -1) //LOG_ERROR_SDL(DR_ERROR);
            {
                LOG_WARNING("Fehler beim Aufruf von SDL_CondSignal"); 
                LOG_ERROR_SDL(DR_ERROR);
            }*/
            return 0;
        }

        void Thread::run()
        {
			static const char* function_name = "Thread::run";
			NotificationList errors;
            //Thread* t = this;
			while (true) {
				try {
					//semaphore.tryWait(100);
					//printf("[Thread::%s] end worker thread\n", __FUNCTION__);
					//break;
					if (exitCalled) return;
					// Lock work mutex
					threadLock();
					//int status = SDL_CondWait(t->condition, t->mutex);
					try {
						condition.wait(mutex);
						if (exitCalled) {
							threadUnlock();
							return;
						}
						int ret = ThreadFunction();
						threadUnlock();
						if (ret)
						{
							//EngineLog.writeToLog("error-code: %d", ret);
							printf("[Thread::%s] error running thread functon: %d, exit thread\n", __FUNCTION__, ret);
							errors.addError(new ParamError(function_name, "error running thread function, exit thread", mPocoThread->getName()));
							return;
						}
					}
					catch (Poco::NullPointerException& e) {
						threadUnlock();
						printf("[Thread::%s] NULL pointer exception\n", __FUNCTION__);
						return;
					}
					catch (Poco::Exception& e) {
						//unlock mutex and exit
						threadUnlock();
						//LOG_ERROR("Fehler in Thread, exit", -1);
						printf("[Thread::%s] exception: %s\n", __FUNCTION__, e.message().data());
						errors.addError(new ParamError(function_name, "poco exception", e.message()));
						errors.addError(new ParamError(function_name, "thread name", mPocoThread->getName()));
						return;
					}

				} catch (Poco::TimeoutException& e) {
					printf("[Thread::%s] timeout exception\n", __FUNCTION__);
					errors.addError(new ParamError(function_name, "poco timeout exception", e.message()));
					errors.addError(new ParamError(function_name, "thread name", mPocoThread->getName()));
				} catch (Poco::Exception& e) {
					printf("[Thread::%s] exception: %s\n", __FUNCTION__, e.message().data());
					errors.addError(new ParamError(function_name, "poco exception 2", e.message()));
					errors.addError(new ParamError(function_name, "thread name", mPocoThread->getName()));
					return;
				}
			}
     
        }
    }
}