从Qutecom中剥离下来改写成静态库的cowutil的测试代码（一）

一、LOGGER

二、Thread

三、Event

四、Date

五、Time

 

.h的代码

 pragma once #include "cowutil/thread/thread.h" #include "cowutil/include/event.h" #include "string" using std::string; //cowutil thread class TestThread : public Thread{ public: TestThread(); ~TestThread(); protected: virtual void run(); private: }; class SubjectBase { public: virtual ~SubjectBase(){} public: virtual void update(int state) = 0; protected: Event<void (SubjectBase* sender,int state)> m_statechged; int m_currentState; private: }; class ObserverBase; class ConcreteSubjectA : public SubjectBase { public: virtual void update(int istate); void linkToOb(ObserverBase* ob); protected: private: }; class ObserverBase { public: virtual ~ObserverBase(){} virtual int subject_state_chg(SubjectBase* sender,int state)=0;//do sth while subject state chged; protected: private: }; class ObserverA : public ObserverBase { public: virtual int subject_state_chg(SubjectBase* sender,int state); protected: private: }; class ObserverB : public ObserverBase { public: virtual int subject_state_chg(SubjectBase* sender,int state); };

.cpp的代码

#include "test.h" #include "stdio.h" #include "cowutil/include/Logger.h" #include "cowutil/include/time.h" #include "cowutil/include/date.h" #include "cowutil/thread/Thread.h" #include "cowutil/include/SafeDelete.h" #include "cowutil/include/event.h" #include "boost/bind.hpp" #include "string" using std::string; void testBoostThread(); void testObserverPattern(); void testLogger(); int main(int argc,char* argv[]) { testLogger(); testBoostThread(); testObserverPattern(); return 0; } void testLogger() { Logger::getInstance()->setLogFileName(string("log.txt")); LOG_INFO("hi this is logger!"); } //线程函数 void TestThread::run() { Time tm; printf("hello this is my thread,try suspend 2 sec/n"); printf("%d:%d:%d - %s/n",tm.getHour(),tm.getMinute(),tm.getSecond(),tm.toString().c_str()); TestThread::msleep(2000); Time tm1; printf("my thread go on running!/n"); printf("%d:%d:%d - %s/n",tm1.getHour(),tm1.getMinute(),tm1.getSecond(),tm1.toString().c_str()); } TestThread::TestThread() { } TestThread::~TestThread() { } void testBoostThread() { Time tm; printf("%d:%d:%d - %s/n",tm.getHour(),tm.getMinute(),tm.getSecond(),tm.toString().c_str()); Date dt; printf("%d-%d-%d - %s/n",dt.getYear(),dt.getMonth(),dt.getDay(),dt.toString().c_str()); Thread* thd = new TestThread; // thd->start();//运行子线程 printf("this is MainThread!/n"); thd->join(); //主线程等待子线程结束 printf("sub thread exit!/n"); OWSAFE_DELETE(thd); } void testObserverPattern() { ConcreteSubjectA subject; ObserverA obA1,obA2; ObserverB obB1,obB2; subject.linkToOb(&obA1); subject.linkToOb(&obA2); subject.linkToOb(&obB1); subject.linkToOb(&obB2); subject.update(1); subject.update(2); subject.update(3); } void ConcreteSubjectA::linkToOb( ObserverBase* ob ) { m_statechged += boost::bind(&ObserverBase::subject_state_chg,ob,_1,_2); } void ConcreteSubjectA::update(int istate) { m_currentState = istate; m_statechged(this,istate); } int ObserverA::subject_state_chg( SubjectBase* sender,int state ) { printf("ObA catch the subject state changing %d!/n",state); return 0; } int ObserverB::subject_state_chg( SubjectBase* sender,int state ) { printf("ObB catch the subject state changing %d!/n",state); return 1; }