src/threads.h

Go to the documentation of this file.

#ifndef __THREADS__
#define __THREADS__

#include "globals.h"
#include <pthread.h>

class ThreadInfo
{
public:
        pthread_t thread;       
        int ret;
        void * (*start_routine)(void *);        
};

// ********************* STARTING THREADS ********************

void * echoRoutine(void *);
ThreadInfo startEchoThread();

void startThreads()
{
        ThreadInfo echo = startEchoThread();

        pthread_join(echo.thread,NULL);
}

// ********************* ECHO ********************

ThreadInfo startEchoThread()
{
        ThreadInfo info;
        info.start_routine = &echoRoutine;
        info.ret = pthread_create( &info.thread, NULL, info.start_routine, NULL);
        return info;
}

void * echoRoutine(void *)
{
        while(1)
        {
                sleep(2);
                p_out << (char *) "[e] :) echo thread" << p_endl;
        }

        return NULL;
}

#endif //__THREADS__

---