/*
 * Copyright 2009, Ingo Weinhold, ingo_weinhold@gmx.de.
 * Distributed under the terms of the MIT License.
 */
#ifndef TEST_THREAD_H
#define TEST_THREAD_H


#include <KernelExport.h>

#include "TestContext.h"


template<typename ObjectType, typename ParameterType>
class TestThread {
public:
	TestThread(ObjectType* object,
		void (ObjectType::*method)(TestContext&, ParameterType*),
		ParameterType* argument)
		:
		fObject(object),
		fMethod(method),
		fArgument(argument)
	{
	}

	thread_id Spawn(const char* name, int32 priority)
	{
		return GlobalTestContext::Current()->SpawnThread(_Entry, name, priority,
			this);
	}

private:
	static status_t _Entry(void* data)
	{
		TestThread* thread = (TestThread*)data;
		(thread->fObject->*thread->fMethod)(
			*GlobalTestContext::Current()->CurrentContext(), thread->fArgument);
		delete thread;
		return B_OK;
	}

private:
	ObjectType*		fObject;
	void			(ObjectType::*fMethod)(TestContext&, ParameterType*);
	ParameterType*	fArgument;
};


template<typename ObjectType, typename ParameterType>
thread_id
SpawnThread(ObjectType* object,
	void (ObjectType::*method)(TestContext&, ParameterType*), const char* name,
	int32 priority, ParameterType* arg)
{
	TestThread<ObjectType, ParameterType>* thread
		= new(std::nothrow) TestThread<ObjectType, ParameterType>(object,
			method, arg);
	if (thread == NULL)
		return B_NO_MEMORY;

	return thread->Spawn(name, priority);
}


#endif	// TEST_THREAD_H