1. 程式人生 > >哲學家就餐問題在 linux 上的程式實現

哲學家就餐問題在 linux 上的程式實現

 
<script src="http://pagead2.googlesyndication.com/pagead/show_ads.js" type="text/javascript"> </script> <iframe name="google_ads_frame" marginwidth="0" marginheight="0" src="http://pagead2.googlesyndication.com/pagead/ads?client=ca-pub-0660578626274101&amp;dt=1181108169986&amp;lmt=1181032340&amp;prev_fmts=120x600_as&amp;format=336x280_as&amp;output=html&amp;correlator=1181108158656&amp;channel=1892283765&amp;url=http%3A%2F%2Fwww.zxbc.cn%2Fhtml%2Fsf%2F0719373052108.html&amp;color_bg=F9FCFE&amp;color_text=363636&amp;color_link=000000&amp;color_url=363636&amp;color_border=FFFFFF&amp;ad_type=text_image&amp;cc=712&amp;flash=9&amp;u_h=1024&amp;u_w=1280&amp;u_ah=994&amp;u_aw=1280&amp;u_cd=32&amp;u_tz=480&amp;u_java=true" frameborder="0" width="336" scrolling="no" height="280" allowtransparency="allowtransparency"></iframe>

與windows 平臺的實現類似,
程式上稍有不同。
PhilosopherDining.cpp
#include <iostream>
#include <string>
#include <pthread.h>
#include <unistd.h>
#include <semaphore.h>
#include "RasUtil.h"
using namespace std;
const unsigned int PHILOSOPHER_NUM=5;
const char THINKING=1;
const char HUNGRY=2;
const char DINING=3;
// each fork has a semaphore
sem_t semph[PHILOSOPHER_NUM];
// Mutex for printing
pthread_mutex_t mutex;
void* philosopherProc(void* param);
int main(int argc, char* argv[])
{
 int i;
 srand(getpid());
 pthread_t philosopherThread[PHILOSOPHER_NUM];
 int phId[PHILOSOPHER_NUM];
 pthread_mutex_init(&mutex, NULL);
 for (i=0; i<PHILOSOPHER_NUM; i++)
 {
         phId[i] = i;
  sem_init(&semph[i], 0, 1);
  pthread_create(&philosopherThread[i], NULL, philosopherProc, (void*)(&phId[i]));
  usleep(50);
 }
 sleep(3);
 return 0;
}
void* philosopherProc(void* param)
{
 int myid;
 char idStr[128];
 char stateStr[128];
 char mystate;
 int ret;
 unsigned int leftFork;
 unsigned int rightFork;
 myid = *((int*)(param));
 RasUtil::intToStr(myid, idStr);
 
 cout << "philosopher " << myid << " begin......" << endl;
 //usleep(10);
 // initial state is THINKING
 mystate = THINKING;
 leftFork = (myid) % PHILOSOPHER_NUM;
 rightFork = (myid + 1) % PHILOSOPHER_NUM;
 while (true)
 {
  switch(mystate)
  {
  case THINKING:
   // changing my state
   mystate = HUNGRY;
   strcpy(stateStr, "HUNGRY");
   break;
  case HUNGRY:
   strcpy(stateStr, "HUNGRY");
   // first test the left fork ...
   ret = sem_trywait(&semph[leftFork]);
   if (ret == 0) 

{
    // left fork is ok, take it up !
    // then test the right fork ...
    ret = sem_trywait(&semph[rightFork]);
    if (ret == 0)
    {
     // right fork is also ok !
     // changing my state
     mystate = DINING;
     strcpy(stateStr, "DINING");
    }
    else
    {
     // right fork is being used by others, so I must put down
     // the left fork.
     sem_post(&semph[leftFork]);
    }
   }
   break;
  case DINING:
   // put down both the left and right fork
   sem_post(&semph[leftFork]);
   sem_post(&semph[rightFork]);
   // changing my state
   mystate = THINKING;
   strcpy(stateStr, "THINKING");
   break;
  }
  // print my state
  pthread_mutex_lock(&mutex);
  cout << "philosopher " << myid << " is : " << stateStr << endl;  
  pthread_mutex_unlock(&mutex);
  
  // sleep a random time : between 1 - 5 s
  int sleepTime; 
  sleepTime = 1 + (int)(5.0*rand()/(RAND_MAX+1.0)); 
  usleep(sleepTime*10);
 }
}
RasUtil.h : 完成整數轉換為字串
#ifndef _RasUtil_h_
#define _RasUtil_h_
class RasUtil
{
public:
 static inline void intToStr(int i, char* str);

};

inline void RasUtil::intToStr(int i, char* str)
{
    int dec;
    int sign;
    char* p;
    p = ecvt(i, 10, &dec, &sign);

strcpy(str, p);
    str[dec] = 0;
}
#endif