Final version

pull/2/head
obaya 2025-05-03 20:09:04 +02:00
parent 3cee7198b9
commit 285200c86e
1 changed files with 33 additions and 21 deletions

View File

@ -3,43 +3,53 @@ package pp;
import java.util.Random; import java.util.Random;
import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class Philosopher extends Thread implements IPhilosopher { public class Philosopher extends Thread implements IPhilosopher {
private int seat; private int seat;
private Philosopher rechts; private Philosopher rechts;
private Philosopher links; private Philosopher links;
private Lock table; private Lock table;
private Condition condition ; private Condition condition;
private volatile boolean stopped; private volatile boolean stopped;
private volatile boolean eating; private volatile boolean eating;
private final Random random; private final Random random;
public Philosopher() { public Philosopher() {
this.random = new Random(); this.random = new Random();
this.seat = 0; this.seat = 0;
this.stopped = false; this.stopped = false;
} }
public static void main(String... args) {
// TODO
}
@Override @Override
public void run() { public void run() {
try { try {
while (this.stopped == false) { while (this.stopped == false) {
think(); think();
eat(); eat();
} }
} catch (InterruptedException e) { } catch (InterruptedException e) {
// Thread was interrupted, exit gracefully // Thread was interrupted, exit gracefully
} }
} }
private void eat() throws InterruptedException { private void eat() throws InterruptedException {
table.lock(); table.lock();
try { try {
while(this.links.eating || this.rechts.eating) while (this.links.eating || this.rechts.eating) {
log(seat, " : isst gerade!");
this.condition.await(); this.condition.await();
this.eating = true; }
}finally {
this.eating = true;
} finally {
table.unlock(); table.unlock();
} }
Thread.sleep(this.random.nextInt(PhilosopherExperiment.MAX_EATING_DURATION_MS)); Thread.sleep(this.random.nextInt(PhilosopherExperiment.MAX_EATING_DURATION_MS));
@ -58,7 +68,6 @@ public class Philosopher extends Thread implements IPhilosopher {
} }
} }
@Override @Override
public void setLeft(IPhilosopher left) { public void setLeft(IPhilosopher left) {
// TODO Auto-generated method stub // TODO Auto-generated method stub
@ -82,7 +91,7 @@ public class Philosopher extends Thread implements IPhilosopher {
public void setTable(Lock table) { public void setTable(Lock table) {
// TODO Auto-generated method stub // TODO Auto-generated method stub
this.table = table; this.table = table;
condition = this.table.newCondition(); condition = this.table.newCondition();
} }
@ -92,4 +101,7 @@ public class Philosopher extends Thread implements IPhilosopher {
this.stopped = true; this.stopped = true;
interrupt(); interrupt();
} }
} }