#ifndef __GENERIC_THREAD_H__
#define __GENERIC_THREAD_H__

#include <OS.h>
#include <Message.h>

class GenericThread
{
	public:
				GenericThread	(const char * a_thread_name = "generic_thread", int32 a_priority = B_NORMAL_PRIORITY, BMessage * a_message = NULL);
		virtual	~GenericThread	(void);

				BMessage *	GetDataStore		(void);
				void		SetDataStore		(BMessage * a_message);

				status_t	Start					(void);
				status_t	Pause					(bool a_do_block = TRUE, bigtime_t a_timeout = 0);
				void		Quit					(void);
				bool		IsPaused				(void);
				bool		HasQuitBeenRequested	(void);
				
				status_t	Suspend				(void);
				status_t	Resume				(void);
				status_t	Kill				(void);
				
				void		ExitWithReturnValue	(status_t a_return_value);
				status_t	SetExitCallback		(void (* a_callback)(void *), void * a_data);
				status_t	WaitForThread		(status_t * a_exit_value);
				
				status_t	Rename			(char * a_name);
				
				status_t	SendData		(int32 a_code, void * a_buffer, size_t a_buffer_size);
				int32		ReceiveData		(thread_id * a_sender, void * a_buffer, size_t a_buffer_size);
				bool		HasData			(void);
			
				status_t	SetPriority		(int32 a_new_priority);

				void		Snooze			(bigtime_t a_microseconds);
				void		SnoozeUntil		(bigtime_t a_microseconds, int a_timebase = B_SYSTEM_TIMEBASE);
	
				
				status_t		GetInfo			(thread_info * a_thread_info);
				thread_id		GetThread		(void);
				team_id			GetTeam			(void);
				char	*		GetName			(void);
				thread_state	GetState		(void);
				sem_id			GetSemaphore	(void);
				int32			GetPriority		(void);
				bigtime_t		GetUserTime		(void);
				bigtime_t		GetKernelTime	(void);
				void	*		GetStackBase	(void);
				void	*		GetStackEnd		(void);

	protected:

		virtual status_t	ThreadFunction		(void);
		virtual status_t    ThreadStartup		(void);
		virtual status_t	ExecuteUnit			(void);
		virtual status_t	ThreadShutdown		(void);
		
		virtual void		ThreadStartupFailed		(status_t a_status);
		virtual void		ExecuteUnitFailed		(status_t a_status);
		virtual void		ThreadShutdownFailed	(status_t a_status);

				void		BeginUnit			(void);	// acquire m_execute_cycle
		 		void		EndUnit				(void);	// release m_execute_cycle
		 		
		BMessage	 *		m_thread_data_store;
				
	private:
	
		static status_t	private_thread_function		(void * a_simple_thread_ptr);
		
		thread_id		m_thread_id;
	
		sem_id			m_execute_unit;	// acq./relase within tread_function.. For Pause()

		bool			m_quit_requested;
		bool			m_thread_is_paused;

};

#endif