#ifndef INCLUDED_THREADS
#define INCLUDED_THREADS

#include <pthread.h>
#include <base.h>


class Threads {
public:
    BASE_NEW_DELETE(Threads);

    /* constructor */
    Threads(int num = 1) {};
    virtual ~Threads() {};

    /* functions */
    virtual void init() = 0;
    virtual int get_mail(int speid, int count, memaddr *ret) = 0; // BLOCKING
    virtual int has_mail(int speid, int count, memaddr *ret) = 0; // NONBLOCK
    virtual void send_mail(int speid, int num, memaddr *data) = 0; // BLOCKING

    /* variables */
    pthread_t *threads;
    int cpu_num;
}  ;

#endif