|
#include <algorithm>
#include <iostream>
#include <vector>
#include <stdio.h>
/*
Slot 一个对象和其对应的pfunc
Signal 媒介,保存Slot Node
emitter "知晓"(一般是聚合)Signal并发起Signal
*/
using namespace std;
template<typename T1>
class SlotBase
{
public:
virtual void Exec(T1 param1) = 0;
};
template<typename T, typename T1>
class SlotImpl : public SlotBase<T1>
{
public:
SlotImpl(T* pObj, void (T::*func)(T1))
{
m_pObj = pObj;
m_Func = func;
}
void Exec( T1 param1)
{
(m_pObj->*m_Func)(param1);
}
private:
T* m_pObj;
void (T::*m_Func)(T1);
};
//node
template<typename T1>
class Slot
{
public:
template<typename T>
Slot(T* pObj, void (T::*func)(T1))
{
m_pSlotBase = new SlotImpl<T,T1>(pObj, func);
}
~Slot()
{
delete m_pSlotBase;
}
void Exec(T1 param1)
{
m_pSlotBase->Exec(param1);
}
private:
SlotBase<T1>* m_pSlotBase;
};
//veteor <node> m_node
template<typename T1>
class Signal
{
public:
template<typename T>
void Bind(T* pObj, void (T::*func)(T1))
{
m_pSlotSet.push_back( new Slot<T1>(pObj,func) );
}
~Signal()
{
for(int i=0;i<(int)m_pSlotSet.size();i++)
{
delete m_pSlotSet[i];
}
}
//Functor
void operator()(T1 param1)
{
for(int i=0;i<(int)m_pSlotSet.size();i++)
{
m_pSlotSet[i]->Exec(param1);
}
}
private:
vector< Slot<T1>* > m_pSlotSet;
};
#define Connect( sender, signal, receiver, method) ( (sender)->signal.Bind(receiver, method) )
class CRecv0
{
public:
void FuncRecv0(int param)
{
printf("CRecv0::FuncRecv0(%d)\n", param);
}
};
class CRecv1
{
public:
void FuncRecv1(int param)
{
printf("CRecv1::FuncRecv1(%d)\n", param);
}
};
//emitter
class CEmit
{
public:
CEmit()
{
m_Value = 0;
}
void EmitValue(int value)
{
if(m_Value != value)
{
m_Value = value;
SigValue(m_Value);
}
}
public:
Signal<int> SigValue;
private:
int m_Value;
};
int main()
{
CRecv0* pRecv0 = new CRecv0;
CRecv1* pRecv1 = new CRecv1;
CEmit* pEmit = new CEmit;
Connect(pEmit, SigValue, pRecv0, &CRecv0::FuncRecv0);
Connect(pEmit, SigValue, pRecv1, &CRecv1::FuncRecv1);
pEmit->EmitValue(10);
pEmit->EmitValue(5);
pEmit->EmitValue(2);
delete pEmit;
delete pRecv0;
delete pRecv1;
return 0;
}
|
