1. #pragma once
2. #include <string>
3. #include <list>
4. #include "Define.h"
5. class IObserver;
6. class ISubject
7. {
8. public:
9. ISubject(void);
10. virtual ~ISubject(void);
11. virtual int Attach(IObserver* pObs) = 0;
12. virtual int Detach(IObserver* pObs) = 0;
13. virtual int Notify() = 0;
14. virtual State GetState() = 0;
15. virtual void SetState(const State& state) = 0;
16. protected:
17. typedef std::list<IObserver*> L_OBS;
18. L_OBS   m_obsArray;
19. };

1. #pragma once
2. #include "ISubject.h"
3. class CSubjectA : public ISubject
4. {
5. public:
6. CSubjectA(void);
7. virtual ~CSubjectA(void);
8. virtual int Attach(IObserver* pObs);
9. virtual int Detach(IObserver* pObs);
10. virtual int Notify();
11. virtual State GetState();
12. virtual void SetState(const State& state);
13. private:
14. State m_state;
15. };

1. #include "CSubjectA.h"
2. #include "IObserver.h"
3. CSubjectA::CSubjectA(void)
4. {
5. }
6. CSubjectA::~CSubjectA(void)
7. {
8. if (!m_obsArray.empty())
9. {
10. m_obsArray.clear();
11. L_OBS().swap(m_obsArray);
12. }
13. }
14. int CSubjectA::Attach( IObserver* pObs )
15. {
16. m_obsArray.push_back(pObs);
17. return 0;
18. }
19. int CSubjectA::Detach( IObserver* pObs )
20. {
21. m_obsArray.remove(pObs);
22. return 0;
23. }
24. int CSubjectA::Notify()
25. {
26. L_OBS::iterator it_beg, it_end=m_obsArray.end();
27. for (it_beg=m_obsArray.begin(); it_beg!=it_end; ++it_beg)
28. {
29. (*it_beg)->Update();
30. }
31. return 0;
32. }
33. State CSubjectA::GetState()
34. {
35. return m_state;
36. }
37. void CSubjectA::SetState( const State& state )
38. {
39. m_state = state;
40. }

1. #pragma once
2. #include "Define.h"
3. class IObserver
4. {
5. public:
6. IObserver(void);
7. virtual ~IObserver(void);
8. virtual int Update() = 0;
9. };

1. #pragma once
2. #include "IObserver.h"
3. class ISubject;
4. class CObserveA : public IObserver
5. {
6. public:
7. CObserveA(ISubject* pSubject);
8. virtual ~CObserveA(void);
9. virtual int Update();
10. private:
11. ISubject* m_pSubject;
12. };

1. #include "CObserveA.h"
2. #include <cstdio>
3. #include "ISubject.h"
4. CObserveA::CObserveA(ISubject* pSubject)
5. :m_pSubject(pSubject)
6. {
7. m_pSubject->Attach(this);
8. }
9. CObserveA::~CObserveA(void)
10. {
11. m_pSubject->Detach(this);
12. }
13. int CObserveA::Update()
14. {
15. State str = m_pSubject->GetState();
16. printf("first get: [%s]\n", str.c_str());
17. return 0;
18. }

1. #include "CSubjectA.h"
2. #include "CObserveA.h"
3. int main()
4. {
5. CSubjectA subA;
6. CObserveA first(&subA);
7. subA.SetState("test set state");
8. subA.Notify();
9. return 0;
10. }

版权声明：本文博客原创文章。博客，未经同意，不得转载。