/// Copyright (c) 2010 Ruben Penalva. All rights reserved.
/// Redistribution and use in source and binary forms, with or without modification, 
/// are permitted provided that the following conditions are met:
///    1. Redistributions of source code must retain the above copyright notice, this 
///    list of conditions and the following disclaimer.
///    2. Redistributions in binary form must reproduce the above copyright notice,
///    this list of conditions and the following disclaimer in the documentation and/or
///    other materials provided with the distribution.
///    3. The name of the author may not be used to endorse or promote products derived
///    from this software without specific prior written permission.
///
/// THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES,
/// INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR 
/// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, 
/// INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED 
/// TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 
/// INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 
/// LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF 
/// THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
#ifndef _THREAD_POOL_H_
#define _THREAD_POOL_H_

#include <windows.h>

#include <boost\utility.hpp>
#include <vector>

namespace TaskBasedFlockSim
{

class TaskContext;
class ITask;

class ThreadPool :
	boost::noncopyable
{
public:
	ThreadPool(void);

	ThreadPool(size_t minThreadsCount, size_t maxThreadsCount);

	~ThreadPool(void);

	void SubmitTasks(TaskContext* context);

private:
	struct TaskCallbackContext
	{
		ThreadPool* m_threadPool;
		ITask* m_task;
		TaskContext* m_context;

		TaskCallbackContext(ThreadPool* threadPool, 
							ITask* task, 
							TaskContext* context)	:	m_threadPool(threadPool), 
														m_task(task),
														m_context(context)
		{
		}

		TaskCallbackContext(const TaskCallbackContext& taskCallbackContext)	:	m_threadPool(taskCallbackContext.m_threadPool), 
																				m_task(taskCallbackContext.m_task),
																				m_context(taskCallbackContext.m_context)
		{
		}

		TaskCallbackContext& operator=(const TaskCallbackContext& taskCallbackContext)
		{
			m_threadPool = taskCallbackContext.m_threadPool;
			m_task = taskCallbackContext.m_task;
			m_context = taskCallbackContext.m_context;

			return *this;
		}
	};

	PTP_POOL m_pool;

	std::vector<TaskCallbackContext> m_taskCallbacksContext;

	void SetDefaultThreadsCount(void);

	void SetThreadsCount(size_t minThreadsCount, size_t maxThreadsCount);

	friend VOID CALLBACK TaskCallback(PTP_CALLBACK_INSTANCE instance, PVOID context);
};

}

#endif