服務器設計筆記(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;
}