src/engine/loop_thread_obj.cpp

Go to the documentation of this file.

#include <time.h>
#include "engine/loop_thread_obj.h"

FastLoopThreadObj::FastLoopThreadObj(const std::string n) : ThreadObj(n)
{
}

FastLoopThreadObj::~FastLoopThreadObj()
{
}

void FastLoopThreadObj::Main()
{
        while(!GetAskStop())
                Loop();
}

// in microseconds
const unsigned int sleep_time_min = 1000;
const unsigned int sleep_time_max = 100000;

// in seconds
const /*unsigned*/ int awake_time = 10; // time before beginning to sleep
const /*unsigned*/ int fall_asleep_time = 20; // time tobe totally asleep

LoopThreadObj::LoopThreadObj(const std::string n) : FastLoopThreadObj(n), sleep_mutex(NORMAL_MUTEX)
{
        //printf("Starting %p : %s", this, n.c_str());
        sleep_time = sleep_time_min;
        time(&last_wake);
}

LoopThreadObj::~LoopThreadObj()
{
        // This would trigger a race condition as
        // the destructor of subclasses has already been
        // called.
        // Make sure sleep_mutex has been released
        //SetAskStop(true);
        //while(!GetStopped())
        //      usleep(50000);
}

void LoopThreadObj::WakeUp()
{
        MUTEX_LOCK(sleep_mutex);
        sleep_time = sleep_time_min;
        time(&last_wake);
        MUTEX_UNLOCK(sleep_mutex);
}

void LoopThreadObj::Main()
{
        while(!GetAskStop())
        {
                //usleep(50000); // Sleep 0.05 sec

                // Increase sleep time if necessary:
                MUTEX_LOCK(sleep_mutex);
                usleep(sleep_time); // Sleep 0.005 sec

                time_t now;
                time(&now);
                if( last_wake + awake_time < /*(unsigned int)*/ now
                &&  last_wake + awake_time + fall_asleep_time > /*(unsigned int)*/now )
                        sleep_time = sleep_time_min + (sleep_time_max - sleep_time_min) * (now - last_wake - awake_time) /  fall_asleep_time;
                else
                        sleep_time = sleep_time_max;

                MUTEX_UNLOCK(sleep_mutex);

                Loop();
        }
}

unsigned int LoopThreadObj::GetSleepTime()
{
        unsigned int tmp;
        MUTEX_LOCK(sleep_mutex);
        tmp = sleep_time;
        MUTEX_UNLOCK(sleep_mutex);
        return tmp;
}

---