|
|
|
#include <windows.h>
#include <stdio.h>
#include <process.h>
#include <time.h>
#include "threads.h"
int main()
{
thread t;
printf("Start programm\n");
t.run_threads(); // run threads
//the main programm should wait on the threads
Sleep(1000);
//when all threads are deleted
printf("End programm\n");
return 0;
}
#include "read_data.h" // thread 1
#include "write_data.h" // thread 2
class thread
{
public:
thread();
~thread();
bool run_threads();
private:
unsigned int count_threads; //anzahl offener threads
// dann startest du die threads
bool thread::run_threads()
{
count_threads++;
_beginthread(thread_read_data);
count_threads++;
_beginthread(thread_write_data);
return true;
}
|
|
|
class Thread
{
public:
Thread();
int Start(void * arg);
protected:
int Run(void * arg);
static void * EntryPoint(void*);
virtual void Setup();
virtual void Execute(void*);
void * Arg() const {return Arg_;}
void Arg(void* a){Arg_ = a;}
private:
THREADID ThreadId_;
void * Arg_;
};
Thread::Thread() {}
int Thread::Start(void * arg)
{
Arg(arg); // store user data
int code = thread_create(Thread::EntryPoint, this, & ThreadId_);
return code;
}
int Thread::Run(void * arg)
{
Setup();
Execute( arg );
}
/*static */
void * Thread::EntryPoint(void * pthis)
{
Thread * pt = (Thread*)pthis;
pthis->Run( Arg() );
}
virtual void Thread::Setup()
{
// Do any setup here
}
virtual void Thread::Execute(void* arg)
{
// Your code goes here
}
|
|
|
