blob: 9ae257e030125bc543f8c868305a7f1609065a97 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
/* ************************************************************************** */
/* */
/* ::: :::::::: */
/* simulation.c :+: :+: :+: */
/* +:+ +:+ +:+ */
/* By: dkaiser <dkaiser@student.42heilbronn.de +#+ +:+ +#+ */
/* +#+#+#+#+#+ +#+ */
/* Created: 2025/01/17 14:38:04 by dkaiser #+# #+# */
/* Updated: 2025/01/27 14:46:08 by dkaiser ### ########.fr */
/* */
/* ************************************************************************** */
#include "philo.h"
int philo_die(t_philo *philo)
{
if (ft_cur_time_in_ms() > philo->last_time_eaten + philo->data->time_to_die)
{
philo->is_alive = 0;
ft_log(philo->id, "has died");
philo->data->simulation_running = 0;
return (1);
}
return (0);
}
void philo_sleep(t_philo *philo)
{
int started_sleeping;
int tts;
started_sleeping = ft_cur_time_in_ms();
tts = philo->data->time_to_sleep;
ft_log(philo->id, "is sleeping");
while (ft_cur_time_in_ms() < started_sleeping + tts)
{
if (philo_die(philo))
return ;
usleep(250);
}
}
void process_philo(void *arg)
{
t_philo *philo;
philo = (t_philo *)arg;
while (philo->data->simulation_running)
{
philo_eat(philo);
if (philo->times_must_eat == 0)
{
pthread_mutex_lock(&philo->data->pme_mutex);
philo->data->philos_must_eat -= 1;
pthread_mutex_unlock(&philo->data->pme_mutex);
}
if (!philo->data->simulation_running)
break ;
if (philo->data->nbr_of_philos < 2)
{
if (philo_die(philo))
break ;
continue ;
}
philo_sleep(philo);
if (!philo->data->simulation_running)
break ;
ft_log(philo->id, "is thinking");
}
}
int run_simulation(int nbr_of_philos, t_philo *philos, t_phdata *data)
{
int i;
int result;
i = 0;
result = EXIT_SUCCESS;
while (i < nbr_of_philos)
{
result = pthread_create(&(philos[i].thread), NULL,
(void *)process_philo, &philos[i]);
if (result != 0)
break ;
i++;
}
while (data->simulation_running)
{
if (data->philos_must_eat <= 0)
data->simulation_running = 0;
}
while (i--)
{
pthread_join(philos[i].thread, NULL);
}
return (result);
}
|
