Philosophers

/* ** i 번째 철학자가 식사를 할 준비가 되었는지 확인한다. ** 양 옆의 철학자가 식사를 하고 있지 않아 젓가락을 모두 이용할 수 있다면, 철학자가 take_chopsticks에서 wait하지 않도록 signal을 보낸다. ** 주어진 조건을 만족하는 경우에는 philo[i]의 값이 1이므로 take_chopsticks에서 Block되지 않고 EATING 할 수 있다. */ check(int i) { if (state[i] == THINKING && state[LEFT] != EATING && state[RIGHT] != EATING) { state[i] = EATING; signal(philo[i]); } } /* ** mutex를 통해 i 번째 철학자의 상태를 변경한다. ** check를 통해 양쪽 철학자의 상태를 확인한다. ** i 번째 철학자는 자신이 식사를 할 수 있을 때까지 기다린다. */ take_chopsticks(int i) { wait(mutex); state[i] = THINKING; check(i); signal(mutex); wait(philo[i]); } /* ** mutex를 통해 i 번째 철학자의 상태를 변경한다. ** check를 통해 왼쪽 철학자와 오른쪽 철학자의 양 옆을 확인한다. ** 둘 중 식사가 가능한 철학자에게 check 내부에서 signal을 보낸다. */ put_chopsticks(int i) { wait(mutex); state[i] = SLEEPING; check(LEFT); check(RIGHT); signal(mutex); } /* ** Solution */ do { ... THINKING ... take_chopsticks(i) ... EATING ... put_chopsticks(i); ... SLEEPING ... } while (1);

./philo number_of_philosophers time_to_die time_to_eat time_to_sleep {number_of_times_each_philosopher_must_eat}

인자값 구조체에 초기화() { 인자값 atoi() 철학자 수만큼 mutex생성() } 인자값구조체를 철학자 구조체에 초기화() { int main() { 인자개수 유효성체크() 인자값 구조체에 초기화() 인자값구조체를 철학자 구조체에 초기화()

#include <stdio.h> #include <pthread.h> #include <unistd.h> #include <stdlib.h> pthread_mutex_t m; void *t_function(void *data) { pid_t pid; // process id pthread_t tid; // thread id pid = getpid(); tid = pthread_self(); char* thread_name = (char*)data; int i = 0; pthread_mutex_lock(&pm); while (i < 5) // 0,1,2 까지만 loop 돌립니다. { // 넘겨받은 쓰레드 이름과 // 현재 process id 와 thread id 를 함께 출력 printf("[%s] pid:%u, tid:%x --- %d\n", thread_name, (unsigned int)pid, (unsigned int)tid, i); i++; sleep(1); // 1초간 대기 } pthread_mutex_unlock(&m); } int main() { pthread_t p_thread[2]; int thr_id; int status; char p1[] = "thread_1"; char p2[] = "thread_2"; char pM[] = "thread_m"; sleep(1); pthread_mutex_init(&m, NULL); thr_id = pthread_create(&p_thread[0], NULL, t_function, (void *)p1); if (thr_id < 0) { perror("thread create error : "); exit(0); } thr_id = pthread_create(&p_thread[1], NULL, t_function, (void *)p2); if (thr_id < 0) { perror("thread create error : "); exit(0); } while(1) ; pthread_join(p_thread[0], (void **)&status); pthread_join(p_thread[1], (void **)&status); printf("언제 종료 될까요?\n"); return (0); }

#include <stdio.h> #include <pthread.h> #include <unistd.h> #include <stdlib.h> pthread_mutex_t m; void *t_function(void *data) { pid_t pid; // process id pthread_t tid; // thread id pid = getpid(); tid = pthread_self(); char* thread_name = (char*)data; int i = 0; // pthread_mutex_lock(&m); while (i < 5) // 0,1,2 까지만 loop 돌립니다. { // 넘겨받은 쓰레드 이름과 // 현재 process id 와 thread id 를 함께 출력 printf("[%s] pid:%u, tid:%x --- %d\n", thread_name, (unsigned int)pid, (unsigned int)tid, i); i++; sleep(1); // 1초간 대기 } // pthread_mutex_unlock(&m); } int main() { pthread_t p_thread[2]; int thr_id; int status; char p1[] = "thread_1"; char p2[] = "thread_2"; char pM[] = "thread_m"; sleep(1); pthread_mutex_init(&m, NULL); thr_id = pthread_create(&p_thread[0], NULL, t_function, (void *)p1); //pthread_detach(p_thread[0]); if (thr_id < 0) { perror("thread create error : "); exit(0); } thr_id = pthread_create(&p_thread[1], NULL, t_function, (void *)p2); //pthread_detach(p_thread[1]); if (thr_id < 0) { perror("thread create error : "); exit(0); } while(1) ; pthread_join(p_thread[0], (void **)&status); pthread_join(p_thread[1], (void **)&status); printf("언제 종료 될까요?\n"); return (0); }