基于log4cxx封装的一个日志类

#include "OneLogWorker.h" void* OneLogWorker::thread_worker(void *data) { OneLogWorker *self = (OneLogWorker *) data; while(self->isRun() ||(!self->isRun() && self->hasLog())) { LogData *d = self->Pop(); if(d) self->doLog(d); else usleep(5); } } OneLogWorker::OneLogWorker(const char* config,const char * logger,int threadnum,int maxlogsize) { log4cxx::PropertyConfigurator::configure(config); m_logger = Logger::getLogger(logger); m_threadnum = threadnum; m_logsize = maxlogsize; m_pool = new MemPool(m_logsize); setIsRun(true); if(!m_pool) exit(1); pthread_mutex_init(&mutex, NULL); for (int i=0 ;i < m_threadnum ; i++) { pthread_create(&m_pid[i],NULL, &(OneLogWorker::thread_worker), this); } } OneLogWorker::~OneLogWorker() { std::deque<LogData*>::iterator iter = m_buffQ.begin(); for(;iter != m_buffQ.end();iter++) { if(*iter) m_pool->Free(*iter); } m_buffQ.clear(); if(m_pool) { delete m_pool; m_pool = NULL; } } void OneLogWorker::waitWorkerEnd() { setIsRun(false); std::map<int,pthread_t>::iterator iter = m_pid.begin(); for(; iter != m_pid.end();iter++) { pthread_join(iter->second, NULL); } } OneLogWorker::LogData* OneLogWorker::Pop() { LogData* buf = NULL; pthread_mutex_lock(&mutex); if(m_buffQ.size()) { buf = m_buffQ.front(); m_buffQ.pop_front(); } pthread_mutex_unlock(&mutex); return buf; } void OneLogWorker::Push(LogData *data) { pthread_mutex_lock(&mutex); m_buffQ.push_back(data); pthread_mutex_unlock(&mutex); } void OneLogWorker::doLog(LogData *data) { if(data && m_logger) { switch(data->type) { case LOG_TYPE_DEBUG: LOG4CXX_DEBUG(m_logger, data->data); break; case LOG_TYPE_INFO: LOG4CXX_INFO(m_logger, data->data); break; case LOG_TYPE_WARN: LOG4CXX_WARN(m_logger, data->data); break; case LOG_TYPE_ERROR: LOG4CXX_ERROR(m_logger, data->data); break; default: break; } m_pool->Free(data); } }