Linux C - Threads

[joanan46]

Buenas tardes gente.

A ver primero de todo decir que en esto de los threads voy un poco flojo. Me cuesta entederlo, pero aqui estoy para ver si me podeis ayudar.

Os pondre la parte del programa que me falla.

El programa va sobre: tengo 3 hilos, 4 semaforos, y dos tablas (aux, num) de int[x]. Un hilo pedira un numero y lo pondra en la tabla aux, el segundo pasara el numero de la tabla aux a la tabla num, y el tercero leera de la tabla num. Todo esto jugando con los semaforos, para que no se avancen los hilos.

Código C:

typedef struct {
    int tnum[K];            //array 1   
    int tnumAux[K];               // array2    //los 2 son arrays circulares.
    unsigned int in;            //en realidad solo necesito esta variable de todas las unsigned que tengo. Me dira si he llegado a final del array, y se pondra a 0 de nuevo.
    unsigned int out;           
    unsigned int num;           
    unsigned int M_in;          
    unsigned int M_out;         
} t_data;
 
pthread_mutex_t mut = PTHREAD_MUTEX_INITIALIZER;
 
sem_t sem1, sem2, sem3, sem4;
 
 
void *f_in (void *d) {
// Atenció al productor
t_data *dt = (t_data *)d;
int car;
int fi=0, err;
 
    //for(fi=0;fi<K;fi++) {7
    do{
    
        sem_wait(&sem1);
        pthread_mutex_lock (&mut);
 
        printf("Pido numero:\n"); 
        err = read(0,&car,1);
 
        dt->tnum[(dt->in)] = car;
        //dt->paella[dt->in] = dt->M_in;
        //printf ("He col·locat l'ou: %d\n", (dt->M_in)++);
        (dt->in)++;
        if (dt->in == K) dt->in = 0;
        (dt->num)++;
        
 
        printf("salimos,  Sem2 en verde:\n", car);
        pthread_mutex_unlock (&mut);
        sem_post(&sem2);
    }while(car!='.');
}
 
int main (int argc, char **argv) {
t_data data;
pthread_t pth[F];
int i;
    data.in = data.out = data.num = data.M_in = data.M_out = 0;
 
    sem_init(&sem1,0,1);
    sem_init(&sem2,0,1);
    sem_init(&sem3,0,1);
    sem_init(&sem4,0,1);
 
    pthread_create (&(pth[0]), NULL, &f_in, (void *)&data);
    pthread_create (&(pth[1]), NULL, &f_ch, (void *)&data);
    pthread_create (&(pth[2]), NULL, &f_out, (void *)&data);
 
    for (i = 0; i<F; i++) pthread_join (pth[i], NULL);
return (0);
}
 

El problema que tengo es que al poner el semaforo sem1 en "rojo", se me bloquea el programa, solo escribo numero pero no sale nada, se queda atontao.

Verdadaramente no se ver el error. Alguien lo ve.

pd: el error o errores ejej.

Saludos