init

philo.c

@@ -0,0 +1,114 @@
+#include "philo.h"
+#include "struct.h"
+#include "time.h"
+#include "data.h"
+#include <pthread.h>
+#include <stdbool.h>
+#include <unistd.h>
+#include "./print.h"
+
+void	philo_destroyer(t_philo *philo)
+{
+	pthread_mutex_destroy(&philo->nb_meal_mutex);
+	pthread_mutex_destroy(&philo->last_sleep_mutex);
+	pthread_mutex_destroy(&philo->last_eat_mutex);
+	free(philo);
+}
+
+bool	check(t_data *data)
+{
+	bool	stop;
+
+	pthread_mutex_lock(&data->stop_mutex);
+	stop = data->stop;
+	pthread_mutex_unlock(&data->stop_mutex);
+	return (stop);
+}
+
+void	eat(t_philo *philo, t_data *data)
+{
+	print_take_a_fork(philo);
+	print_take_a_fork(philo);
+	print_eating(philo);
+	usleep(data->eat_time * 1000);
+	pthread_mutex_lock(&philo->nb_meal_mutex);
+	philo->nb_meal++;
+	pthread_mutex_unlock(&philo->nb_meal_mutex);
+	pthread_mutex_lock(&data->forks_mutex);
+	data->forks[philo->id] = 1;
+	data->forks[(philo->id + 1) % (data->nb_philos) + 1] = 1;
+	pthread_mutex_unlock(&data->forks_mutex);
+}
+
+bool	philo_eat(t_philo *philo, t_data *data)
+{
+	bool	left_fork;
+	bool	right_fork;
+
+	left_fork = 0;
+	right_fork = 0;
+	while (left_fork == 0 || right_fork == 0)
+	{
+		if (check(data))
+			return (1);
+		pthread_mutex_lock(&data->forks_mutex);
+		left_fork = data->forks[philo->id]; 
+		right_fork = data->forks[(philo->id + 1) % (data->nb_philos) + 1];
+		if (right_fork && left_fork)
+		{
+			data->forks[philo->id] = !left_fork;
+			data->forks[(philo->id + 1) % (data->nb_philos) + 1] = !right_fork;
+		}
+		pthread_mutex_unlock(&data->forks_mutex);
+	}
+	eat(philo, data);
+	pthread_mutex_lock(&philo->last_eat_mutex);
+	philo->last_eat = get_time();
+	pthread_mutex_unlock(&philo->last_eat_mutex);
+	return (0);
+}
+
+void	philo_sleep(t_data *data, t_philo *philo)
+{
+	print_sleeping(philo);
+	usleep(data->sleep_time * 1000);
+}
+
+
+void	*philo_routine(void *arg)
+{
+	t_philo		*philo;
+	t_data		*data;
+
+	philo = arg;
+	data = philo->data;
+	while (true)
+	{
+		print_thinking(philo);
+		check(data);
+		philo_eat(philo, data);
+		check(data);
+		print_thinking(philo);
+		if (check(data))
+			return (NULL);
+		philo_sleep(data, philo);
+	}
+	return (NULL);
+}
+
+t_philo	*philo_init(t_data *data)
+{
+	t_philo			*philo;
+	static size_t	id = 0;
+
+	philo = malloc(sizeof(t_philo));
+	if (philo == NULL)
+		return (NULL);
+	philo->id = id++;
+	philo->data = data;
+	philo->nb_meal = 0;
+	pthread_mutex_init(&philo->nb_meal_mutex, NULL);
+	pthread_mutex_init(&philo->nb_meal_mutex, NULL);
+	pthread_mutex_init(&philo->nb_meal_mutex, NULL);
+	return (philo);
+}