/*
 * Copyright 2007 Stephen Liu
 * For license terms, see the file COPYING along with this library.
 */


#ifndef __spthreadpool_hpp__
#define __spthreadpool_hpp__

#include "spthread.hpp"

typedef struct tagSP_Thread SP_Thread_t;

class SP_ThreadPool {
public:
	typedef void ( * DispatchFunc_t )( void * );

	SP_ThreadPool( int maxThreads, const char * tag = 0 );
	~SP_ThreadPool();

	/// @return 0 : OK, -1 : cannot create thread
	int dispatch( DispatchFunc_t dispatchFunc, void *arg );

	int getMaxThreads();

private:
	char * mTag;

	int mMaxThreads;
	int mIndex;
	int mTotal;
	int mIsShutdown;

	sp_thread_mutex_t mMainMutex;
	sp_thread_cond_t mIdleCond;
	sp_thread_cond_t mFullCond;
	sp_thread_cond_t mEmptyCond;

	SP_Thread_t ** mThreadList;

	static sp_thread_result_t SP_THREAD_CALL wrapperFunc( void * );
	int saveThread( SP_Thread_t * thread );
};

#endif