* 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
