Scheduler for JPF

src/cz/cuni/mff/d3s/deeco/scheduling/MultithreadedSchedulerJPF.java

@@ -0,0 +1,92 @@
+package cz.cuni.mff.d3s.deeco.scheduling;
+
+import java.util.HashSet;
+import java.util.Set;
+
+import cz.cuni.mff.d3s.deeco.invokable.SchedulableProcess;
+import cz.cuni.mff.d3s.deeco.invokable.TriggeredSchedulableProcess;
+import cz.cuni.mff.d3s.deeco.knowledge.KnowledgeManager;
+
+/**
+ * Special scheduler for testing via JPF.
+ * 
+ * Each task has a separate thread and is executed in the endless cycle.
+ * Timing is ignored (due to GC - see comments in code)
+ * 
+ * @author alf
+ *
+ */
+public class MultithreadedSchedulerJPF extends Scheduler {
+
+  private Set<Thread> threads;
+
+  public MultithreadedSchedulerJPF(KnowledgeManager km) {
+    super();
+    this.km = km;
+    this.threads = new HashSet<Thread>();
+
+
+    // JPF Optimization -> earlier class loading a clinit call (in the single threaded part)
+    // Shrinks state space
+    @SuppressWarnings("unused")
+    ETriggerType e = ETriggerType.COORDINATOR;  
+  }
+
+  @Override
+  public void start() {
+    if (!running) {
+      for (SchedulableProcess sp : periodicProcesses) {
+        startPeriodicProcess(sp,
+            ((ProcessPeriodicSchedule) sp.scheduling).interval);
+      }
+      for (TriggeredSchedulableProcess tsp : triggeredProcesses) {
+        if (true) {
+          assert(false); // ALF: Unsupported now
+        }
+        km.registerListener(tsp);
+      }
+      km.switchListening(true);
+
+    }
+  }
+
+  @Override
+  public void stop() {
+    if (running) {
+      for (Thread t : threads) {
+        t.interrupt();
+      }
+      km.switchListening(false);
+    }
+  }
+
+  private void startPeriodicProcess(SchedulableProcess process, long period) {
+    // Note Period is intentionally ignored - GC
+    // Because of the stop the world Garbage collector, which can postpone all threads and then any thread can execute its own action
+    Thread t = new Thread(new PeriodicProcessRunner(process));
+    threads.add(t);
+    t.start();
+  }
+
+  class PeriodicProcessRunner implements Runnable {
+
+    final private SchedulableProcess process;
+
+    public PeriodicProcessRunner(SchedulableProcess process) {
+      this.process = process;
+    }
+
+    @Override
+    public void run() {
+      while (!Thread.interrupted())
+      {
+        try {
+          process.invoke();
+        } catch (Exception e) {
+          System.out.println("Process scheduled exception!");
+        }
+      }
+    }
+  }
+
+}