我正在尝试解决哲学家就餐问题(问题: https ://en.wikipedia.org/wiki/Dining_philosophers_problem ),我找到了以下代码的解决方案。解决方案使用信号量和一个互斥体。我自己实现了忙等待简单信号量,因为 C++ 不提供信号量。我不明白互斥锁锁定take_forks
和put_forks
功能的目的是什么。
我试图找到我的问题的答案,但我找不到。所以我在stackoverflow中问。
我的问题是:
- 互斥锁锁定
take_forks
和put_forks
功能的目的是什么?(什么会导致竞争条件发生?) - 这个解决方案的名称是什么?这是仲裁解决方案吗?
这是我的代码
#include <mutex>
#include <thread>
#define N 5
#define THINKING 0
#define HUNGRY 1
#define EATING 2
typedef int sem_t;
void sem_up(sem_t* semaphore) {
(*semaphore)++;
}
void sem_down(sem_t* semaphore) {
while (*semaphore == 0) {}
(*semaphore)--;
}
std::mutex mutualExclusion;
char philosopherState[N] = {THINKING};
sem_t philosopherSemaphore[N] = { 0 };
void test(short i) {
if (philosopherState[i] == HUNGRY && philosopherState[(i + 1) % N] != EATING && philosopherState[(i + N - 1) % N] != EATING) {
philosopherState[i] = EATING;
sem_up(&philosopherSemaphore[i]);
}
}
void think(short p) {
//some code
}
void eat() {
//some code
}
void take_forks(short i) {
::mutualExclusion.lock();
philosopherState[i] = HUNGRY;
test(i);
::mutualExclusion.unlock();
sem_down(&philosopherSemaphore[i]);
}
void put_forks(short i) {
::mutualExclusion.lock();
philosopherState[i] = THINKING;
test((i + 1) % N);
test((i + N - 1) % N);
::mutualExclusion.unlock();
}
void philosopher(short i) {
while (1) {
think();
take_forks(i);
eat();
put_forks(i);
}
}
我希望互斥锁必须test
起作用,因为这是我发现的竞争条件的唯一原因。