blob: 4ce51782ace732a1f5edb633819cdd489b358b4c (
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
98
99
100
|
/* ************************************************************************** */
/* */
/* ::: :::::::: */
/* simulation.c :+: :+: :+: */
/* +:+ +:+ +:+ */
/* By: dkaiser <dkaiser@student.42heilbronn.de +#+ +:+ +#+ */
/* +#+#+#+#+#+ +#+ */
/* Created: 2025/01/17 14:38:04 by dkaiser #+# #+# */
/* Updated: 2025/01/28 13:41:46 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, "has died");
stop_simulation(philo->data);
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, "is sleeping");
while (ft_cur_time_in_ms() < started_sleeping + tts)
{
if (philo_die(philo))
return ;
if (!is_simulation_running(philo->data))
return ;
usleep(250);
}
}
void process_philo(void *arg)
{
t_philo *philo;
philo = (t_philo *)arg;
while (is_simulation_running(philo->data))
{
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 (!is_simulation_running(philo->data))
break ;
if (philo->data->nbr_of_philos < 2)
{
if (philo_die(philo))
break ;
continue ;
}
philo_sleep(philo);
if (!is_simulation_running(philo->data))
break ;
ft_log(philo, "is thinking");
}
}
int run_simulation(int nbr_of_philos, t_philo *philos, t_phdata *data)
{
int i;
int result;
i = 0;
result = EXIT_SUCCESS;
data->simulation_running = 1;
while (i < nbr_of_philos)
{
result = pthread_create(&(philos[i].thread), NULL,
(void *)process_philo, &philos[i]);
if (result != 0)
break ;
i++;
}
if (result != EXIT_SUCCESS)
stop_simulation(data);
while (is_simulation_running(data))
{
if (data->philos_must_eat <= 0)
stop_simulation(data);
}
while (i--)
pthread_join(philos[i].thread, NULL);
return (result);
}
|
