Informatik 12/13 (G9)

Diese Seite ist nicht editierbar. Sie können den Quelltext sehen, jedoch nicht verändern. Kontaktieren Sie den Administrator, wenn Sie glauben, dass hier ein Fehler vorliegt.
<HTML>

<div class="java-online" style="height: 60vh; width: 100%" data-java-online="{'withBottomPanel': false, 'id': 'PassiveWaitingSeveralProducersConsumers'}">

<script type="text/plain" title="PassiveWaitingSPC.java">
Tresen t = new Tresen(1);
for (int i = 0; i < 5; i++) {
   new Bob(t, 100, "Bob " + i).start();
   new Lisa(t, "Lisa " + i).start(); 
}



class Bob extends Thread {
   Tresen tresen;
   int anzahlPizzenTodo;
   int lastTimePizzaBaked = System.currentTimeMillis();

   
   Bob(Tresen tresen, int anzahlPizzenTodo, String name) {
      super(name);
      this.tresen = tresen;
      this.anzahlPizzenTodo = anzahlPizzenTodo;
   }

   public void run() {
      while (anzahlPizzenTodo > 0) {
         tresen.legPizzaDrauf();
         anzahlPizzenTodo--;

         // Wir warten, bis Bob die nächste Pizza gebacken hat.
         // Das ist nicht informatikrelevant, macht den Vergleich mit 
         // aktivem Warten aber realistischer.
         int timeToBakeNextPizza = Random.randint(10, 100);
         int timeSinceLastPizzaBaked = System.currentTimeMillis() - lastTimePizzaBaked;
         if(timeSinceLastPizzaBaked < timeToBakeNextPizza) {
            Thread.sleep(timeToBakeNextPizza - timeSinceLastPizzaBaked);
            lastTimePizzaBaked = System.currentTimeMillis();
         }

      }
      println(Thread.currentThread().getName() + " ist fertig!", Color.aquamarine);
      // System.exit(0);
   }

}

class Lisa extends Thread {
   Tresen tresen;
   int anzahlPizzenServiert = 0;

   Lisa(Tresen tresen, String name) {
      super(name);
      this.tresen = tresen;
   }

   public void run() {
      while (true) {
         tresen.holPizzaAb();
         anzahlPizzenServiert++;
         if(anzahlPizzenServiert % 10 == 0) {
            println(Thread.currentThread().getName() + " hat " + anzahlPizzenServiert + " Pizzen serviert.");
         }
         // Lisa bringt jetzt die Pizza zu den Kunden:
         Thread.sleep(Random.randint(10, 100)); 
      }
   }

}

class Tresen {
   
   int anzahlPizzen = 0;
   int kapazität;

   public Tresen(int kapazität) {
      this.kapazität = kapazität;
   }

   synchronized void legPizzaDrauf() {
      while (anzahlPizzen == kapazität) {
         wait();                 // aktueller Thread geht in den Wartezustand und blockiert
      }
      anzahlPizzen++;
      notifyAll();                  // beliebigen Thread aus dem Wartezustand "aufwecken"
   }

   synchronized void holPizzaAb() {
      while (anzahlPizzen == 0) {
         wait();                 // aktueller Thread geht in den Wartezustand und blockiert
      }
      anzahlPizzen--;
      notifyAll();                  // beliebigen Thread aus dem Wartezustand "aufwecken"
   }

}</script>

</div>

</HTML>