1234567891011121314151617181920212223242526272829303132333435363738394041424344454647 |
- #pragma once
- #include <map>
- #include "CcosLock.h"
- using namespace std;
- /*
- /// <summary>
- /// eBus BLOBStreamClient 对象
- /// </summary>
- class BusClientWrapper
- {
- bool m_IsConnected;
- BUSC::BLOBStreamClient* m_pClient;
- public:
- BusClientWrapper();
- ~BusClientWrapper();
- bool IsConnected();
- void SetConnection(bool Flag);
- BUSC::BLOBStreamClient* GetBusClient();
- };
- /// <summary>
- /// 为每一个线程自动分配一个 eBus StreamClient
- /// </summary>
- class ClientsThreadMap : public CcosLock
- {
- map<DWORD, BusClientWrapper*> m_ThreadMap;
- public:
- ClientsThreadMap();
- virtual ~ClientsThreadMap();
- //bool RegistThread(PVOID pCcosThread);
- BusClientWrapper* operator [](DWORD Tid);
- void UnRegistThread(DWORD Tid);
- void Disconnected();
- void Clear();
- };
- */
|