Linux - Simulacion de Caja con Multiproceso

#include <stdlib.h>

#include <stdio.h>

#include <unistd.h>

#include <time.h>

#include <semaphore.h>

#include <pthread.h>

#include <string.h>	// memmove()

int	cola[1024], counter;

sem_t	sem_caja, sem_cola;

/* */

int extract_user() {

	int user;

	sem_wait(&sem_caja);

        sem_wait(&sem_cola);

	user = cola[0];

	memmove(&cola, &cola[1], 1023);

	cola[1023] = -1;

	sem_post(&sem_cola);

	return user;

}

/* */

int insert_user() {

	int i;

	sem_wait(&sem_cola);

	for(i = 0; i < 1024; i++) {

		if(cola[i] < 0) {

			cola[i] = ++counter;

			printf("Nuevo usuario num %d en pos %d de la cola\n", counter, i);

			break;

		}

	}

	sem_post(&sem_cola);

	sem_post(&sem_caja);

	if(i >= 1023) {

		printf("La cola está a tope, la cerramos permanentemente.\n");

		return(1);

	}

	return 0;

}

/* */

void* caja(void *data) {

	int secs;

	while(1) {

		int user = extract_user();

		printf("Usuario num %d pasa a caja\n", user);

		secs = (rand() % 10) + 5;

		sleep(secs);

		printf("Usuario num %d finaliza\n", user);

	}

}

/* */

int main(int argc, char *argv[]) {

	int secs;

	pthread_t t_caja;

	srand(time(NULL));

	sem_init(&sem_caja, 0, 0);

	sem_init(&sem_cola, 0, 1);

	for(int i = 0; i < 1024; i++) {

		cola[i] = -1;

	}

	counter = 0;

	pthread_create(&t_caja, NULL, caja, NULL);

	while(1) {

		secs = (rand() % 20) + 2;

		sleep(secs);

		if(insert_user())

			break;

	}

	pthread_join(t_caja, NULL);

}