From 13abb5f313ffb28fce7e4a9a31124d29967bec10 Mon Sep 17 00:00:00 2001
From: Gregor Kleen <gkleen@yggdrasil.li>
Date: Mon, 25 Jan 2016 11:43:50 +0000
Subject: OSS 12

---
 ws2015/oss/blaetter/12/Speicher.java | 75 ++++++++++++++++++++++++++++++++++++
 1 file changed, 75 insertions(+)
 create mode 100644 ws2015/oss/blaetter/12/Speicher.java

(limited to 'ws2015/oss/blaetter/12/Speicher.java')

diff --git a/ws2015/oss/blaetter/12/Speicher.java b/ws2015/oss/blaetter/12/Speicher.java
new file mode 100644
index 0000000..b521466
--- /dev/null
+++ b/ws2015/oss/blaetter/12/Speicher.java
@@ -0,0 +1,75 @@
+public class Speicher {
+    private int anzahl_schreibewuensche; // Alter variablenname 'anzahl_der_schreibewunsche' war inkonsistent mit den anderen
+    private int anzahl_leser;
+    private boolean schreiber_aktiv;
+    private String daten;
+	
+    public Speicher (String initial) {
+	anzahl_schreibewuensche = 0;
+	anzahl_leser = 0;
+	schreiber_aktiv = false;
+	daten = initial;
+    }
+
+    public synchronized void leserecht_holen(int prozess_id) { // Alte methodennamen 'leserechte_holen' und 'leserechte_freigeben' waren inkonsistent
+	while ( schreiber_aktiv || anzahl_schreibewuensche > 0) { // Blocken bis kein Prozess schreibrecht hat oder will
+	    try {
+		this.wait();
+	    } catch (InterruptedException ie) {}
+	}
+		
+	anzahl_leser++;
+		
+	System.out.println("Prozess " + prozess_id
+			   + " ==> Leserecht erhalten (" + anzahl_leser + " Leser)");
+    }
+
+    public synchronized void leserecht_freigeben(int prozess_id) {
+	anzahl_leser--;
+	System.out.println("Prozess " + prozess_id
+			   + " ==> Leserecht freigegeben (" + anzahl_leser + " Leser)");
+	this.notifyAll(); // Alle blockenden Prozesse aufwecken (nacheinander)
+    }
+
+    public synchronized void schreibrecht_holen(int prozess_id) {
+	anzahl_schreibewuensche++;
+
+	while (schreiber_aktiv || anzahl_leser > 0) { // Blocken bis alle leser/schreiber fertig
+	    try {
+		this.wait();
+	    } catch (InterruptedException ie) {}
+	}
+
+	// Anfang kritischer Bereich
+
+	schreiber_aktiv = true;
+	anzahl_schreibewuensche--;
+
+	// Ende kritischer Bereich
+
+	System.out.println("Prozess " + prozess_id
+			   + " ==> Schreibrecht erhalten (" + anzahl_leser + " Leser)");
+    }
+
+    public synchronized void schreibrecht_freigeben(int prozess_id) {
+	schreiber_aktiv = false;
+	System.out.println("Prozess " + prozess_id
+			   + " ==> Schreibrecht freigegeben (" + anzahl_leser + " Leser)");
+	this.notifyAll();
+    }
+
+    public String lese() {
+	try { // Das Lesen dauert etwas...
+	    Thread.sleep(400);
+	} catch (InterruptedException e) {}
+	return daten;
+    }
+
+    public synchronized void schreibe(String s) {
+	try { // Das Schreiben dauert etwas...
+	    Thread.sleep(400);
+	} catch (InterruptedException e) {}
+	this.daten = s;
+    }
+
+}
-- 
cgit v1.2.3