n_thread_pool.h

Go to the documentation of this file.

 
#ifndef NILOREA_THREAD_POOL_LIBRARY
#define NILOREA_THREAD_POOL_LIBRARY
 
#ifdef __cplusplus
extern "C"
{
#endif
 
#include "n_list.h"
#include <pthread.h>
#include <semaphore.h>
 
 
#define SYNCED_PROC 1
#define DIRECT_PROC 2
#define NOQUEUE 4
#define IDLE_PROC 8
#define WAITING_PROC 16
#define RUNNING_PROC 32
#define RUNNING_THREAD 64
#define EXITING_THREAD 128
#define EXITED_THREAD 256
#define NO_LOCK 512
 
typedef struct THREAD_POOL_NODE
{
    void *(*func)(void *param);
 
    void *param ;
 
    int type ;
    int state ;
    int thread_state ;
    pthread_t thr ;
 
    sem_t th_start,
          th_end ;
 
    pthread_mutex_t lock ;
 
                struct THREAD_POOL *thread_pool ;
 
} THREAD_POOL_NODE ;
 
 
typedef struct THREAD_POOL
{
    THREAD_POOL_NODE **thread_list ;
 
    int max_threads ;
    int nb_max_waiting ;
    int nb_actives ;
 
    pthread_mutex_t lock ;
 
                sem_t nb_tasks ;
 
    LIST *waiting_list ;
 
} THREAD_POOL ;
 
 
 
typedef struct THREAD_WAITING_PROC
{
    void *(*func)(void *param);
    void *param ;
 
} THREAD_WAITING_PROC ;
 
/* get number of core of current system */
int get_nb_cpu_cores();
/* allocate a new thread pool */
THREAD_POOL *new_thread_pool( int nbmaxthr, int nb_max_waiting );
/* add a function to run in an available thread inside a pool */
int add_threaded_process( THREAD_POOL *thread_pool, void *(*func_ptr)(void *param), void *param, int mode );
/* tell all the waiting threads to start their associated process */
int start_threaded_pool( THREAD_POOL *thread_pool );
/* wait for all the threads in the pool to terminate processing, blocking but light on the CPU as there is no polling */
int wait_for_synced_threaded_pool( THREAD_POOL *thread_pool );
/* wait for all running threads to finish */
int wait_for_threaded_pool( THREAD_POOL *thread_pool, int delay );
/* destroy all running threads */
int destroy_threaded_pool( THREAD_POOL **thread_pool, int delay );
/* try to add some waiting process on some free thread slots, else do nothing */
int refresh_thread_pool( THREAD_POOL *thread_pool );
 
#ifdef __cplusplus
}
#endif
 
#endif