00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034
00035
00036 #ifndef _ResourceQueueEvents_H_
00037 #define _ResourceQueueEvents_H_
00038
00039 #include "ResourceQueue.h"
00040 #include "ThreadPool.h"
00041
00042 KOMODIA_NAMESPACE_START
00043
00044 template<class T>
00045 class CResourceQueueEvents : public CResourceQueue<T>
00046 {
00047 public:
00048
00049 typedef CResourceQueueEvents<T> ResourceClass;
00050
00051
00052 typedef void (*ResourceProc)(ResourceClass* pResourcePool,
00053 LPVOID lpData);
00054 typedef ResourceProc LPResourceProc;
00055 public:
00056
00057 virtual BOOL RequestResource(T& rResource,
00058 unsigned long ulTimeout=INFINITE);
00059
00060
00061 CResourceQueueEvents(LPResourceProc pSpawnProc,
00062 LPVOID lpData,
00063 unsigned long ulMaxItems=0,
00064 unsigned long ulThreads=5,
00065 CResourceQueue<T>::LPDeleteProc pCleanUPProc=NULL);
00066 virtual ~CResourceQueueEvents();
00067 private:
00068
00069 CResourceQueueEvents(const CResourceQueueEvents& rEvents);
00070
00071
00072 CResourceQueueEvents& operator=(const CResourceQueueEvents& rEvents);
00073
00074
00075 void AddRequest();
00076
00077
00078 static void SubmitThread(LPVOID lpData);
00079
00080
00081 LPResourceProc m_pSpawnProc;
00082
00083
00084 LPVOID m_lpUserData;
00085
00086
00087 CThreadPool* m_pPool;
00088 };
00089
00090 #define CResourceQueueEvents_Class "CResourceQueueEvents"
00091
00092 template<class T>
00093 CResourceQueueEvents<T>::CResourceQueueEvents(LPResourceProc pSpawnProc,
00094 LPVOID lpData,
00095 unsigned long ulMaxItems,
00096 unsigned long ulThreads,
00097 CResourceQueue<T>::LPDeleteProc pCleanUPProc) : CResourceQueue<T>(pCleanUPProc,
00098 ulMaxItems),
00099 m_pSpawnProc(pSpawnProc),
00100 m_lpUserData(lpData),
00101 m_pPool(NULL)
00102 {
00103 try
00104 {
00105
00106 SetName(CResourceQueueEvents_Class);
00107
00108
00109 if (!m_pSpawnProc)
00110 {
00111
00112 ReportError("CResourceQueueEvents","No spawn proc!");
00113
00114
00115 throw std::string("No spawn proc!");
00116 }
00117
00118
00119 m_pPool=new CThreadPool(ulThreads);
00120 }
00121 ERROR_HANDLER_RETHROW("CResourceQueueEvents")
00122 }
00123
00124 template<class T>
00125 CResourceQueueEvents<T>::~CResourceQueueEvents()
00126 {
00127 try
00128 {
00129
00130 delete m_pPool;
00131 }
00132 ERROR_HANDLER("~CResourceQueueEvents")
00133 }
00134
00135 template<class T>
00136 BOOL CResourceQueueEvents<T>::RequestResource(T& rResource,
00137 unsigned long ulTimeout)
00138 {
00139 try
00140 {
00141
00142 AddRequest();
00143
00144
00145 return CResourceQueue<T>::RequestResource(rResource,
00146 ulTimeout);
00147 }
00148 ERROR_HANDLER_RETURN("RequestResource",FALSE)
00149 }
00150
00151 template<class T>
00152 void CResourceQueueEvents<T>::AddRequest()
00153 {
00154 try
00155 {
00156
00157 m_pPool->SubmitJob(SubmitThread,
00158 (LPVOID)this);
00159 }
00160 ERROR_HANDLER_RETHROW("AddRequest")
00161 }
00162
00163 template<class T>
00164 void CResourceQueueEvents<T>::SubmitThread(LPVOID lpData)
00165 {
00166 try
00167 {
00168
00169 CResourceQueueEvents<T>* pClass;
00170 pClass=(CResourceQueueEvents<T>*)lpData;
00171
00172
00173 (*pClass->m_pSpawnProc)(pClass,
00174 pClass->m_lpUserData);
00175 }
00176 ERROR_HANDLER_STATIC(CResourceQueueEvents_Class,"SubmitThread")
00177 }
00178
00179 KOMODIA_NAMESPACE_END
00180
00181 #endif