main.c

Vai alla documentazione di questo file.

#include <stdio.h>
#include <unistd.h>
#include "thpool.h"
#include "errore.h"

/*static int r=0;       
void *test(void * arg){
        printf("Hello World !\n");
        return 0;
}

int main(int argc,char* argv[]){
        int i=0;
        th_pool * pool = NULL;
        sigset_t set;   
        /* Questa maschera ignora tutti i segnali */
        if (sigfillset(&set) == -1){
                sys_err(__FILE__,__LINE__,"Main: error sigfillset",errno);
                exit(EXIT_FAILURE);
        }

        /* Inizializzo un pool di thread di dimensione 5 e
         * con un numero massimo di job in attesa nella coda di 10 */
        if (!(pool = poolInit(5, 10, &set))){
                exit(EXIT_FAILURE);
        }

        /* Creo dei job fittizzi da fare eseguire al pool */
        for (i=0; i<20; i++){
                while (poolDispatcher(pool, test, NULL)==-5){
                        sleep (1);
                }
        }

        /* Arresto il pool di threads e libero le risorse */
        poolDestroy(pool);

        return 0;
}