thpool.h

#ifndef POOL_H_
#define POOL_H_

#include <stdlib.h>
#include <pthread.h>
#include <signal.h>

#include "errore.h"

#ifndef NULL
#define NULL   ((void *) 0)
#endif

typedef struct joblist{
        void *(*start_routine)(void*);
        void * arg;
        struct joblist * next;
} joblist;

typedef struct ThreadPool{
        volatile sig_atomic_t quitflag;
        volatile sig_atomic_t shutdown;
        sigset_t * signalmask;          
        int pool_size;                          
        int job_max;                            
        int job_size;                           
        joblist * firstjob;                     
        joblist * lastjob;                      
        pthread_t * tids;                       
        pthread_mutex_t lock;
        pthread_cond_t notempty;        
        pthread_cond_t empty;           
} th_pool;

th_pool * poolInit(int dim, int job_max, sigset_t *set);

int poolDispatcher(th_pool *pool, void *(*start_routine)(void*), void *arg);

int poolDestroy(th_pool *pool);

#endif /* POOL_H_ */