1

私はダイニング哲学者問題 (5 人の哲学者) の簡単な解決策を実装しようとしていますが、私の解決策は次のロジックに基づいています。

sem_t S[philosophers_number]
for each philosopher
{
    while(TRUE)
    {
        if(current philosopher number != last philosopher)
        {
            thinking()

            //i is number of current philosopher
            sem_wait(take_chopstick(S[(i+1) % philosophers_number])) // right chopstick
            sem_wait(take_chopstick(S[i])) // left chopstick

            eat()

            sem_post(put_chopstick(S[(i+1) % philosophers_number]))
            sem_post(put_chopstick(S[i]))
        }
        else
        {
            thinking()

            //i is number of current philosopher
            sem_wait(take_chopstick(S[i])) // left chopstick
            sem_wait(take_chopstick(S[(i+1) % philosophers_number])) // right chopstick

            eat()

            sem_post(put_chopstick(S[i]))          
            sem_post(put_chopstick(S[(i+1) % philosophers_number]))  
        }
}

各哲学者は最初に 3 秒以内に考える

次に、右の箸が利用できる場合は哲学者がそれを取り、左の箸も利用可能な場合は哲学者もそれを取り、3 秒以内に食べ始めます。

次に哲学者は箸を置き、他の哲学者が使えるようにします。

循環的な待機を避けるために、最後の哲学者の場合、最初に左の箸を選び、次に右の箸を選び、同じプロセスに進みます

このロジックに基づいて実装したコードは次のとおりです。

#include <stdio.h>
#include <string.h>
#include <pthread.h>
#include <semaphore.h>
#include <unistd.h>
#include <stdlib.h>

#define THREADS 5
sem_t chopstick[THREADS];

void thinking(int ph_num)
{
    printf("philosopher %d is thinking\n", ph_num);
    int t = rand() % 3;
    sleep(t);// up to 3 secs thinking
}

void eat(int ph_num)
{
    printf("philosopher %d is eating\n", ph_num);
    int t = rand() % 3;
    sleep(t);// up to 3 secs eating
}

void *philosopher(void * ph_num )
{
    int num=(int)ph_num;
    while(1)
    {
        if(num < THREADS - 1)
        {
            thinking(num);
            
            //pick up right chopstick
            sem_wait(&chopstick[(num + 1) % THREADS]);

            //to make deadlocks absolutly happen, wait 1 sec then pickup left chopstick
            sleep(1);
            
            //pick up left chopstick
            sem_wait(&chopstick[num]);
        
            eat(num);   

            //put down right chopstick
            sem_post(&chopstick[(num + 1) % THREADS]);

            //put down left chopstick
            sem_post(&chopstick[num]);
        }

        else // last one pick left chopstick first, instead of right one to avoid cyclic wait
        {
                        thinking(num);

                        //pick up left chopstick
                        sem_wait(&chopstick[num]);

                        //to make deadlocks absolutly happen, wait 1 sec then pickup left chopstick 
                        sleep(1); 
                        
                        //pick up right chopstick
                        sem_wait(&chopstick[(num + 1) % THREADS]);

                        eat(num);

                        //put down left chopstick
                        sem_post(&chopstick[num]);

                        //put down right chopstick
                        sem_post(&chopstick[(num + 1) % THREADS]);
        }
    }

    pthread_exit((void *)num);
}

int main ()
{
    for(int i = 0; i < THREADS; i++)
    {
        sem_init(&chopstick[i],0,1);
    }

    pthread_t threads[THREADS];
    
    for(int i = 0; i < THREADS; i++)
        pthread_create(&threads[i], NULL, philosopher, (void *)i);
    
    for(int i = 0; i < THREADS; i++)
        pthread_join(threads[i],NULL);
    return 0;
}

しかし、このコードのデバッグ中に問題が発生しましchopstick[i]た。0以前sem_wait(&chopstick[num])は現在のスレッドをブロックする代わりに、箸がsem_wait()持ち運べるようになるまで、哲学者は実際の箸なしで食事を始めました。

私の問題がどこにあるかを理解するのを手伝ってくれる人はいますか?

4

1 に答える 1