This commit is contained in:
kinou-p 2022-03-01 11:50:02 +01:00
parent 641e225ded
commit 54365381ab
2 changed files with 60 additions and 23 deletions

76
main.c
View File

@ -18,6 +18,7 @@ s_arg *create_data(int argc, char **argv)
data = malloc(sizeof(s_arg)); data = malloc(sizeof(s_arg));
*data->death = 1; *data->death = 1;
data->nb_full_philo = 0;
data->nb_philo = ft_atoi(argv[1]); data->nb_philo = ft_atoi(argv[1]);
data->time_to_die = ft_atoi(argv[2]); data->time_to_die = ft_atoi(argv[2]);
data->time_to_eat = ft_atoi(argv[3]); data->time_to_eat = ft_atoi(argv[3]);
@ -27,7 +28,6 @@ s_arg *create_data(int argc, char **argv)
data->must_eat = ft_atoi(argv[5]); data->must_eat = ft_atoi(argv[5]);
else else
data->must_eat = -1; data->must_eat = -1;
//data->time_start = get_time();
return (data); return (data);
} }
@ -41,10 +41,10 @@ void put_event(s_philo philo, char *event)
void philo_take_fork(s_philo philo) void philo_take_fork(s_philo philo)
{ {
pthread_mutex_lock(philo.right_fork);
put_event(philo, "has taken a fork");
pthread_mutex_lock(philo.left_fork); pthread_mutex_lock(philo.left_fork);
put_event(philo, "has taken a fork"); put_event(philo, "has taken a fork");
pthread_mutex_lock(philo.right_fork);
put_event(philo, "has taken a fork");
} }
void philo_eat(s_philo *philo_tmp) void philo_eat(s_philo *philo_tmp)
@ -63,20 +63,31 @@ void philo_eat(s_philo *philo_tmp)
put_event(philo, "is thinking"); put_event(philo, "is thinking");
} }
void *death_check(void *tmp) void *death_checker(s_philo *philo, s_arg *data)
{ {
s_philo *philo; int i;
philo = (s_philo *)tmp; i = 0;
while (*philo->data->death) while (1)
{ {
if (get_time() - *philo->last_eat > philo->data->time_to_die) i = -1;
while (i++ < data->nb_philo - 1 && philo[i].data->death)
{ {
*philo->data->death = 0; if (get_time() - *philo[i].last_eat > data->time_to_die && philo[i].must_eat)
{
*philo[i].data->death = 0;
pthread_mutex_lock(philo->display); pthread_mutex_lock(philo->display);
printf("%ldms Philo N°%d is died\n", get_time() - philo->data->time_start, philo->philo_id); printf("%ldms Philo N°%d is died\n", get_time() - data->time_start, philo[i].philo_id);
printf("End: one philo died\n");
exit(1); exit(1);
} }
else if (data->nb_full_philo == data->nb_philo)
{
pthread_mutex_lock(philo->display);
printf("End: all philo are full\n");
exit(1);
}
}
} }
return (0); return (0);
} }
@ -87,20 +98,16 @@ void *routine(void *tmp)
pthread_t death; pthread_t death;
philo = (s_philo *)tmp; philo = (s_philo *)tmp;
if (philo->philo_id == 5)
usleep(1530494976);
//usleep(100000);
*philo->last_eat = get_time(); *philo->last_eat = get_time();
pthread_create(&death, 0, &death_check, philo); //if (philo->philo_id % 2)
pthread_detach(death); // usleep(15000);
while (1 && *philo->data->death && philo->must_eat) while (1 && *philo->data->death && philo->must_eat && philo->data->nb_full_philo != philo->data->nb_philo)
{ {
philo_eat(philo); philo_eat(philo);
philo->must_eat--; philo->must_eat--;
}
if (!philo->must_eat) if (!philo->must_eat)
printf("philo n%d is full\n", philo->philo_id); philo->data->nb_full_philo++;
}
return (0); return (0);
} }
@ -134,7 +141,6 @@ s_philo *create_philo(s_arg *data)
philo[i].right_fork = philo[(i + 1) % data->nb_philo].left_fork; philo[i].right_fork = philo[(i + 1) % data->nb_philo].left_fork;
i++; i++;
} }
//philo[i].right_fork = philo[0].left_fork;
return (philo); return (philo);
} }
@ -150,6 +156,7 @@ int start_philo(s_philo *philo, s_arg *data)
usleep(10); usleep(10);
i++; i++;
} }
death_checker(philo, data);
i = 0; i = 0;
while (i < data->nb_philo) while (i < data->nb_philo)
{ {
@ -158,14 +165,43 @@ int start_philo(s_philo *philo, s_arg *data)
return (0); return (0);
} }
int check_arg(int argc, char **argv)
{
int i;
int j;
j= 0;
i = 1;
if (argc != 5 && argc != 6)
return (1);
while (argv[i])
{
j = 0;
while (argv[i][j])
{
if (argv[i][j] > '9' || argv[i][j] < '0')
return (1);
j++;
}
i++;
}
return (0);
}
int main(int argc, char **argv) int main(int argc, char **argv)
{ {
s_arg *data; s_arg *data;
s_philo *philo; s_philo *philo;
if (check_arg(argc, argv))
{
printf("Bad arguments\n");
return (0);
}
data = create_data(argc, argv); data = create_data(argc, argv);
philo = create_philo(data); philo = create_philo(data);
start_philo(philo, data ); start_philo(philo, data );
return (0);
} }

View File

@ -20,6 +20,7 @@
typedef struct s_list typedef struct s_list
{ {
int nb_philo; int nb_philo;
int nb_full_philo;
int time_to_die; int time_to_die;
int time_to_eat; int time_to_eat;
int time_to_sleep; int time_to_sleep;