aboutsummaryrefslogtreecommitdiff
path: root/philo/src/philo_eat.c
blob: 05f2cec1c36a7c9710b288cc0f0eb2a1ca5f941e (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
/* ************************************************************************** */
/*                                                                            */
/*                                                        :::      ::::::::   */
/*   philo_eat.c                                        :+:      :+:    :+:   */
/*                                                    +:+ +:+         +:+     */
/*   By: dkaiser <dkaiser@student.42heilbronn.de    +#+  +:+       +#+        */
/*                                                +#+#+#+#+#+   +#+           */
/*   Created: 2025/01/21 18:15:40 by dkaiser           #+#    #+#             */
/*   Updated: 2025/01/27 14:37:24 by dkaiser          ###   ########.fr       */
/*                                                                            */
/* ************************************************************************** */

#include "ft_utils.h"
#include "philo.h"
#include <pthread.h>

static void	take_fork(t_philo *philo, t_fork *fork)
{
	pthread_mutex_lock(&fork->mutex);
	if (fork->owner == 0)
	{
		fork->owner = philo->id;
		ft_log(philo->id, "has taken a fork");
	}
	pthread_mutex_unlock(&fork->mutex);
}

static void	release_fork(t_fork *fork)
{
	pthread_mutex_lock(&fork->mutex);
	fork->owner = 0;
	pthread_mutex_unlock(&fork->mutex);
}

static void	eat(t_philo *philo, t_fork *left_fork, t_fork *right_fork)
{
	int	started_eating;

	ft_log(philo->id, "is eating");
	started_eating = ft_cur_time_in_ms();
	while (ft_cur_time_in_ms() < started_eating + philo->data->time_to_eat)
	{
		if (!philo->data->simulation_running)
			return ;
		if (philo_die(philo))
			return ;
		usleep(500);
	}
	philo->last_time_eaten = ft_cur_time_in_ms();
	philo->times_must_eat -= 1;
	release_fork(left_fork);
	release_fork(right_fork);
}

void	philo_eat(t_philo *philo)
{
	t_fork	*left_fork;
	t_fork	*right_fork;

	left_fork = &philo->data->forks[philo->id - 1];
	right_fork = &philo->data->forks[philo->id % philo->data->nbr_of_philos];
	while (left_fork->owner != philo->id || right_fork->owner != philo->id)
	{
		if (philo->id % 2 == 0)
			take_fork(philo, right_fork);
		else if (philo->id % 2 == 1)
			usleep(500);
		take_fork(philo, left_fork);
		take_fork(philo, right_fork);
		if (!philo->data->simulation_running)
			return ;
		if (philo_die(philo))
			return ;
		if (left_fork->owner == philo->id && right_fork->owner == philo->id)
			break ;
		if (philo->id % 2 == 0)
			usleep(500);
	}
	if (philo->data->nbr_of_philos > 1)
		eat(philo, left_fork, right_fork);
}