#ifndef __THREAD_POOL_HPP__
#define __THREAD_POOL_HPP__

#include <queue>
#include <boost/thread.hpp>
#include <boost/function.hpp>
#include <boost/utility.hpp>

class thread_pool : boost::noncopyable {
public:
	typedef boost::function<void()> function_type;

private:
	boost::thread_group threads;
	std::queue<function_type> work;
	boost::mutex work_mutex;
	boost::condition work_condition;
	bool running;

	void worker();

public:
	thread_pool(unsigned short threadcount);
	~thread_pool();

	void queue(const function_type &fn);
};

#endif