#include "stdafx.h"
#include "CGlassPool.h"


#define DEFAULT_GLASS_POOL_SIZE				1024

namespace SERVO {
	CGlassPool::CGlassPool()
	{
		InitializeCriticalSection(&m_criticalSection);
	}


	CGlassPool::~CGlassPool()
	{
		DeleteCriticalSection(&m_criticalSection);
	}

	void CGlassPool::initPool()
	{
		auto onReleaseAny = [&](void* pAny) -> void {
			// »ØÊÕGlass
			freeGlass((CGlass*)pAny);
		};


		// ·ÖÅäCGlass³Ø
		Lock();
		for (int i = 0; i < DEFAULT_GLASS_POOL_SIZE; i++) {
			CGlass* pGlass = new CGlass();
			pGlass->setOnRelease(onReleaseAny);
			m_lsitAvailable.push_back(pGlass);
		}
		Unlock();
	}

	void CGlassPool::term()
	{
		Lock();
		for (auto item : m_lsitAvailable) {
			delete item;
		}
		m_lsitAvailable.clear();

		for (auto item : m_mapOccupation) {
			delete item.second;
		}
		m_mapOccupation.clear();
		Unlock();
	}

	CGlass* CGlassPool::allocaGlass()
	{

		Lock();
		CGlass* pGlass = NULL;
		if (!m_lsitAvailable.empty()) {
			pGlass = m_lsitAvailable.front();
			m_lsitAvailable.pop_front();
			m_mapOccupation[pGlass] = pGlass;
		}

		Unlock();

		return pGlass;
	}

	void CGlassPool::freeGlass(CGlass* pGlass)
	{
		// »ØÊÕCAny
		Lock();
		pGlass->reset();
		auto iter = m_mapOccupation.find(pGlass);
		if (iter != m_mapOccupation.end()) {
			m_lsitAvailable.push_back(iter->second);
			m_mapOccupation.erase(iter);
		}
		Unlock();
	}

	int CGlassPool::getAvailableSize()
	{
		Lock();
		int nSize = (int)(m_lsitAvailable.size());
		Unlock();

		return nSize;
	}
}