lösningsförslag

.classpath

+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" path="src"/>
+	<classpathentry combineaccessrules="false" kind="src" path="/tenta-200819"/>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER">
+		<attributes>
+			<attribute name="module" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="lib" path="/tenta-200819/exam.jar"/>
+	<classpathentry kind="output" path="bin"/>
+</classpath>

.project

+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>tenta-200819-losning</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+	</natures>
+</projectDescription>

README.md

-# Lösningsförslag EDAP10 2020-08-19
+# Lösningsförslag, EDAP10 Flertrådad programmering 200819
 
+### Tåguppgift (hemuppgift 1-3): totalt 14p
+
+Uppgift 1-2 (kod): totalt 8p
+
+Uppgift 3.1-3.3: 2p/fråga (1p för a-uppgift, 1p för b-uppgift), totalt 6p
+
+Vi publicerar inget lösningsförslag eftersom denna uppgift numera är en del av laboration 2 i kursen.
+
+### Watchdog-övervakning (hemuppgift 4): totalt 14p
+
+### Teorifrågor (muntlig tentamen 200821): totalt 14p
+
+7 teorifrågor x 2p.
+
+## Totalsumma 42p (godkänt: 21p)

src/liveness/LivenessTracker.java

+package liveness;
+
+import java.util.HashMap;
+import java.util.Map;
+
+// totalt: 14p
+// -- lämpligt attribut, mappar tråd till timeout    2p
+// -- lagrar rätt timeout i reportActivity           2p
+// -- hittar rätt timeout i awaitTimeout             2p
+// -- övervakningstråd                               2p
+// -- rätt signalering (notify-wait)                 2p
+// -- rätt blockering i awaitTimeout                 2p
+// -- hanterar fallet timeout <= 0                   1p
+// -- korrekt monitor i övrigt (synchronized)        1p
+public abstract class LivenessTracker {
+
+    private final Map<Thread,Long> timeouts = new HashMap<>();
+
+    public void initialize() {
+        new Thread(() -> {
+            try {
+                while (true) {
+                    Thread t = awaitTimeout();
+                    timeoutAlert(t);
+                }
+            } catch (InterruptedException unexpected) {
+                throw new Error(unexpected);
+            }
+         }).start();
+    }
+    
+    public synchronized void reportActivity(long timeout) {
+        long now = System.currentTimeMillis();
+        Thread t = Thread.currentThread();
+
+        timeouts.remove(t);
+
+        if (timeout > 0) {
+            timeouts.put(t, now + timeout);
+            notifyAll();            
+        }
+    }
+
+    protected abstract void timeoutAlert(Thread t);
+
+    private Map.Entry<Thread,Long> mostImminent() {
+        Map.Entry<Thread,Long> mostImminent = null;
+        for (Map.Entry<Thread,Long> entry : timeouts.entrySet()) {
+            if (mostImminent == null || entry.getValue() < mostImminent.getValue()) {
+                mostImminent = entry;
+            }
+        }
+        return mostImminent;
+    }
+
+    private synchronized Thread awaitTimeout() throws InterruptedException {
+        long now = System.currentTimeMillis();
+        while (true) {
+            Map.Entry<Thread,Long> next = mostImminent();
+
+            if (next == null) {
+                wait();
+            } else if (next.getValue() > now) {
+                wait(next.getValue() - now);
+            }
+
+            now = System.currentTimeMillis();
+            next = mostImminent();
+            if (next.getValue() <= now) {
+                Thread timedOut = next.getKey();
+                timeouts.remove(timedOut);
+                return timedOut;
+            }
+        }
+    }
+}
\ No newline at end of file