简单的LogicWorker

头文件

#define _LOGICWORKER_H

#include <ace/Task.h>
#include <ace/Synch.h>

#include "AdLog/ADDLoggerMacros.h"
#include "StringUtil/StringPair.h"
#include "StringUtil/StringLib.h"
#include "Udpd/UDPServer.h"

class LogicWorker : public ACE_Task<ACE_MT_SYNCH>
{
  public:

    virtual int close();
    virtual int open(void*);
    virtual void set_threads(unsigned int threads);
    virtual int svc();

    void set_udp_server(UDPServer *udpserver);
    static LogicWorker* instance();


  protected:
    UDPServer *udpserver_;
    unsigned int threads_;
    LogicWorker();
    ~LogicWorker(){};
  private:
    static LogicWorker * inst_;


};
#endif

实现

#include "LogicWorker.h"
#include <cctype>
#include <string>
#include <iterator>


LogicWorker *LogicWorker::inst_ = NULL;


LogicWorker *LogicWorker::instance()
{
    if (inst_ == NULL)
        inst_ = new LogicWorker();
    return inst_;
}

LogicWorker::LogicWorker()
{

}

int LogicWorker::close()
{
    return 0;
}
int LogicWorker::open(void*)
{
    return activate(THR_NEW_LWP|THR_JOINABLE, threads_);
}

void LogicWorker::set_threads(unsigned int threads)
{
    threads_ = threads;
}
void LogicWorker::set_udp_server(UDPServer *udpserver)
{
    udpserver_ = udpserver;
}
int LogicWorker::svc()
{

    while(1)
    {
        //sleep(1);
// 具体实现

    }
    return 0;
}