服务器设计笔记(1)-----定时器的实现(C++)

/*
 * Thread.cpp
 *
 *  Created on: Sep 11, 2012
 *      Author: root
  */

#include  " Thread.h "

Thread::Thread() {
     //  TODO Auto-generated constructor stub

}

Thread::~Thread() {
     //  TODO Auto-generated destructor stub
}

void* Thread::thread_entry( void* para)
{
    Thread *pThread = static_cast<Thread *>(para);
     return pThread->run();
}

int Thread::start( void)
{
     if(pthread_create(&pid, 0,thread_entry,static_cast< void *>( this)) <  0)
    {
        pthread_detach( this->pid);
         return - 1;
    }
     return  0;
}

int Thread::cancel( void)
{
    pthread_cancel( this->pid);
     return  0;
}

/*
 * Timer.cpp
 *
 *  Created on: Sep 11, 2012
 *      Author: root
  */

#include <unistd.h>
#include <time.h>
#include <sys/time.h>
#include  " Timer.h "


TimerThread* TimerThread::_instance;



TimerThread::TimerThread()
{

}

TimerThread::~TimerThread()
{

}

void* TimerThread::run( void)
{
     while( true)
    {
        unsigned  int start_clock = get_systime_clock();
         this->_timer_list.sort();
        list<Timer>::iterator iter;
         for(iter =  this->_timer_list.begin();
                iter !=  this->_timer_list.end();
                    iter ++)
        {
            iter->leftsecs --;
             if(iter->leftsecs ==  0)
            {
                iter->_callback();
                iter->leftsecs = iter->_interval;
            }
        }
        unsigned  int end_clock = get_systime_clock();

        usleep( 1000 + start_clock - end_clock);
    }
     return ( void*) 0;
}

void TimerThread::Register(Timer _timer)
{
     this->_timer_list.push_back(_timer);
}

void TimerThread::unRegister(Timer _timer)
{
     this->_timer_list.remove(_timer);
}

TimerThread* TimerThread::get_instance()
{
     if(_instance == NULL)
    {
        _instance =  new TimerThread();
    }
     return _instance;
}



unsigned  int get_systime_clock()
{
     struct timeval now;
    gettimeofday(&now,NULL);
     return now.tv_sec* 1000 + now.tv_usec/ 1000;
}

// ============================================================================
//  Name        : test.cpp
//  Author      : archy
//  Version     :
//  Copyright   : Your copyright notice
//  Description : Hello World in C++, Ansi-style
// ============================================================================

#include <iostream>
#include < string>
#include <stdio.h>
#include <sys/types.h>

#include  " Timer.h "


using  namespace std;

int handle_timeout()
{
    unsigned  int time = get_systime_clock();
    printf( " time out,%u\n ",time);
     return  0;
}

int main()
{
    Timer _timer;
    _timer.open( 1,handle_timeout);
    TIMERMANAGE->Register(_timer);
    TIMERMANAGE->start();
    getchar();
     return  0;
}